Class: EventMachine::Protocols::Zmq2::PreRouter

Inherits:
Socket
  • Object
show all
Defined in:
lib/em/protocols/zmq2/router.rb

Overview

ZMQ socket which acts like Router but without outgoing message queueing. It counts first message string as peer identity when sending message and prepends socket identity to message on receiving.

Direct Known Subclasses

PreRep, Router

Instance Method Summary collapse

Instance Method Details

#receive_message(message) ⇒ Object

Raises:

  • (NoMethodError) 


15
16
17
 
# File 'lib/em/protocols/zmq2/router.rb', line 15

def receive_message(message)
  raise NoMethodError
end

#receive_message_and_peer(message, peer_identity) ⇒ Object

:nodoc:



10
11
12
13
 
# File 'lib/em/protocols/zmq2/router.rb', line 10

def receive_message_and_peer(message, peer_identity) # :nodoc:
  message.unshift(peer_identity)
  receive_message(message)
end

#send_message(message, even_if_busy = false) ⇒ Object 



19
20
21
22
23
24
 
# File 'lib/em/protocols/zmq2/router.rb', line 19

def send_message(message, even_if_busy = false)
  if connect = choose_peer(message.first, even_if_busy)
    connect.send_strings(message[1..-1])
    true
  end
end