Class: BitBroker::Subscriber

Inherits:
Broker
  • Object
show all
Defined in:
lib/bitbroker/broker.rb

Constant Summary collapse

SIGNAL_TERM = 
'TERM'

Constants inherited from Broker

Broker::ENCRYPT_ALGORITHM, Broker::RKEY_DATA, Broker::RKEY_METADATA

Instance Method Summary collapse

Methods inherited from Broker

#finish

Constructor Details

#initialize(config) ⇒ Subscriber

Returns a new instance of Subscriber.



66
67
68
 
# File 'lib/bitbroker/broker.rb', line 66

def initialize(config)
  super(config)
end

Instance Method Details

#recv_data(&block) ⇒ Object 



70
71
72
 
# File 'lib/bitbroker/broker.rb', line 70

def recv_data(&block)
  recv(RKEY_DATA, &block)
end

#recv_metadata(&block) ⇒ Object 



73
74
75
 
# File 'lib/bitbroker/broker.rb', line 73

def recv_metadata(&block)
  recv(RKEY_METADATA, &block)
end

#recv_p_data(&block) ⇒ Object 



76
77
78
 
# File 'lib/bitbroker/broker.rb', line 76

def recv_p_data(&block)
  recv(RKEY_DATA + Mac.addr, &block)
end

#recv_p_metadata(&block) ⇒ Object 



79
80
81
 
# File 'lib/bitbroker/broker.rb', line 79

def recv_p_metadata(&block)
  recv(RKEY_METADATA + Mac.addr, &block)
end