Class: DripDrop::ZMQBaseHandler

Inherits:

BaseHandler

• Object
• BaseHandler
• DripDrop::ZMQBaseHandler

show all

Defined in:

lib/dripdrop/handlers/zeromq.rb

Instance Attribute Summary (collapse)

• - (Object) address readonly

  Returns the value of attribute address.

• - (Object) socket readonly

  Returns the value of attribute socket.

• - (Object) socket_ctype readonly

  Returns the value of attribute socket_ctype.

Instance Method Summary (collapse)

• - (ZMQBaseHandler) initialize(zaddress, zm_reactor, socket_ctype, opts = {}) constructor

  A new instance of ZMQBaseHandler.

• - (Object) on_attach(socket)
• - (Object) on_recv(msg_format = :dripdrop, &block)

14
15
16
17
18
19
20
21

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

def initialize(zaddress,zm_reactor,socket_ctype,opts={})
  @zaddress     = zaddress
  @address      = @zaddress.to_s
  @zm_reactor   = zm_reactor
  @socket_ctype = socket_ctype # :bind or :connect
  @debug        = opts[:debug] # TODO: Start actually using this
  @opts         = opts
end

12
13
14

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

def address
  @address
end

12
13
14

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

def socket
  @socket
end

12
13
14

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

def socket_ctype
  @socket_ctype
end

23
24
25
26
27
28
29
30
31
32

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

def on_attach(socket)
  @socket = socket
  if    @socket_ctype == :bind
    socket.bind(@zaddress)
  elsif @socket_ctype == :connect
    socket.connect(@zaddress)
  else
    raise "Unsupported socket ctype '#{@socket_ctype}'. Expected :bind or :connect"
  end
end

34
35
36
37
38

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

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