Class: EventMachine::Protocols::Zmq2::Rep

Inherits:

Router

• Object
• Socket
• PreRouter
• Router
• EventMachine::Protocols::Zmq2::Rep

Includes:

RepMixin

Defined in:

lib/em/protocols/zmq2/rep.rb

Overview

ZMQ socket which acts like REP

class EchoBangRep < EM::Protocols::Zmq2::Rep
  def receive_request(message, envelope)
    message << "!"
    if send_reply(message, envelope)
      puts "reply sent successfuly (or placed into queue)"
    end
  end
end
rep = EchoBangRep.new
rep.bind('ipc://rep')

Method Summary

Methods included from RepMixin

#receive_message, #receive_request, #send_reply

Methods inherited from Router

#send_message

Methods included from QueuePerPeer

#initialize, #peer_free, #register_peer, #unregister_peer

Methods inherited from PreRouter

#receive_message, #receive_message_and_peer, #send_message