Method: Hope::Source::Sub#initialize

Defined in:
lib/hope/source/sub.rb

#initialize(name, opts = {}) ⇒ Sub

Returns a new instance of Sub.



7
8
9
10
11
12
13
14
15
 
# File 'lib/hope/source/sub.rb', line 7

def initialize name, opts={}
  @name = name
  @socket = opts["socket"] || "ipc://hope"
  @event_type = opts["event_type"]
  @received = { :success => 0, :errors => 0, :latest_error => "" }
  @sub = Hope.ctx.connect ZMQ::SUB, @socket, self
  @sub.subscribe name
  Hope::Source.register self
end