Class: DripDrop::ZMQPubHandler

Inherits:
ZMQBaseHandler show all
Includes:
ZMQWritableHandler
Defined in:
lib/dripdrop/handlers/zeromq.rb

Instance Attribute Summary

Attributes inherited from ZMQBaseHandler

#connection

Instance Method Summary collapse

Methods included from ZMQWritableHandler

#initialize, #on_writable

Methods inherited from ZMQBaseHandler

#address, #initialize, #on_recv, #post_setup

Instance Method Details

#send_message(message) ⇒ Object

Sends a message along



143
144
145
146
147
148
149
150
 
# File 'lib/dripdrop/handlers/zeromq.rb', line 143

def send_message(message)
  dd_message = dd_messagify(message)
  if dd_message.is_a?(DripDrop::Message)
    super([dd_message.name, dd_message.encoded])
  else
    super(message)
  end
end