Class: DripDrop::ZMQBaseHandler

Inherits:

BaseHandler

• Object
• BaseHandler
• DripDrop::ZMQBaseHandler

Defined in:

lib/dripdrop/handlers/zeromq.rb

Direct Known Subclasses

ZMQPubHandler, ZMQPullHandler, ZMQPushHandler, ZMQSubHandler, ZMQXRepHandler, DripDrop::ZMQXRepHandler::Response, ZMQXReqHandler

Instance Attribute Summary

• #connection ⇒ Object

  Returns the value of attribute connection.

Instance Method Summary

• #address ⇒ Object
• #initialize(opts = {}) ⇒ ZMQBaseHandler constructor

  A new instance of ZMQBaseHandler.

• #on_recv(msg_format = :dripdrop, &block) ⇒ Object
• #post_setup ⇒ Object

  Triggered after a handler is setup.

Constructor Details

#initialize(opts = {}) ⇒ ZMQBaseHandler

Returns a new instance of ZMQBaseHandler.

# File 'lib/dripdrop/handlers/zeromq.rb', line 16

def initialize(opts={})
  @opts         = opts
  @connection   = nil
  @msg_format   = opts[:msg_format] || :dripdrop
end

Instance Attribute Details

#connection ⇒ Object

Returns the value of attribute connection.

# File 'lib/dripdrop/handlers/zeromq.rb', line 14

def connection
  @connection
end

Instance Method Details

#address ⇒ Object

# File 'lib/dripdrop/handlers/zeromq.rb', line 28

def address
  self.connection.address
end

#on_recv(msg_format = :dripdrop, &block) ⇒ Object

# File 'lib/dripdrop/handlers/zeromq.rb', line 22

def on_recv(msg_format=:dripdrop,&block)
  @msg_format = msg_format
  @recv_cbak = block
  self
end

#post_setup ⇒ Object

Triggered after a handler is setup

# File 'lib/dripdrop/handlers/zeromq.rb', line 33

def post_setup; end