Module: ZMQMachine::Server::XREP

Includes:
Base, RoutingEnvelope
Included in:
ROUTER
Defined in:
lib/zm/server/rep.rb

Instance Method Summary collapse

Methods included from RoutingEnvelope

#routing_strings, #save_routing

Methods included from Base

#initialize, #on_attach, #on_readable_error, #on_writable, #on_writable_error, #shutdown, #write

Instance Method Details

#on_readable(socket, messages, envelope) ⇒ Object 



21
22
23
24
25
26
 
# File 'lib/zm/server/rep.rb', line 21

def on_readable socket, messages, envelope
  @routing = save_routing envelope

  @on_read.call socket, messages, envelope
  close_messages(envelope + messages)
end