Method: DripDrop::Agent#send_message

Defined in:
lib/dripdrop/agent.rb

#send_message(name, body, head = {}) ⇒ Object

Sends a DripDrop::Message to the socket



29
30
31
32
33
34
35
36
37
38
 
# File 'lib/dripdrop/agent.rb', line 29

def send_message(name,body,head={})
  message = DripDrop::Message.new(name,:body => body, :head => head).encoded
  if ZMQGEM == :rbzmq
    @socket.send name, ZMQ::SNDMORE
    @socket.send message
  else
    @socket.send_string name, ZMQ::SNDMORE
    @socket.send_string message
  end
end