Class: DripDrop::ZMQXRepHandler
- Inherits:
-
ZMQBaseHandler
- Object
- BaseHandler
- ZMQBaseHandler
- DripDrop::ZMQXRepHandler
- Includes:
- ZMQReadableHandler, ZMQWritableHandler
- Defined in:
- lib/dripdrop/handlers/zeromq.rb
Defined Under Namespace
Classes: Response
Instance Attribute Summary
Attributes included from ZMQReadableHandler
Attributes inherited from ZMQBaseHandler
Instance Method Summary collapse
-
#initialize(*args) ⇒ ZMQXRepHandler
constructor
A new instance of ZMQXRepHandler.
- #on_readable(socket, messages) ⇒ Object
- #send_message(message, identities, seq) ⇒ Object
Methods included from ZMQReadableHandler
Methods included from ZMQWritableHandler
Methods inherited from ZMQBaseHandler
#address, #on_recv, #post_setup
Methods inherited from BaseHandler
#handle_error, #on_error, #print_exception
Constructor Details
#initialize(*args) ⇒ ZMQXRepHandler
Returns a new instance of ZMQXRepHandler.
187 188 189 |
# File 'lib/dripdrop/handlers/zeromq.rb', line 187 def initialize(*args) super(*args) end |
Instance Method Details
#on_readable(socket, messages) ⇒ Object
191 192 193 194 195 196 197 198 199 200 201 202 |
# File 'lib/dripdrop/handlers/zeromq.rb', line 191 def on_readable(socket,) if @msg_format == :dripdrop identities = [0..-2].map {|m| m.copy_out_string} body = .last.copy_out_string = (body) seq = .head[SEQ_CTR_KEY] response = ZMQXRepHandler::Response.new(self, identities,seq) @recv_cbak.call(,response) else super(socket,) end end |
#send_message(message, identities, seq) ⇒ Object
204 205 206 207 208 209 210 211 212 213 214 |
# File 'lib/dripdrop/handlers/zeromq.rb', line 204 def (,identities,seq) if .is_a?(DripDrop::Message) .head[SEQ_CTR_KEY] = seq resp = identities + ['', .encoded] super(resp) else resp = identities + ['', ] super(resp) end end |