Class: AcpcTableManager::Receiver

Inherits:
CommunicatorComponent show all
Defined in:
lib/acpc_table_manager.rb

Direct Known Subclasses

ProxyReceiver, TableManagerReceiver

Instance Attribute Summary

Attributes inherited from CommunicatorComponent

#channel

Instance Method Summary collapse

Methods inherited from CommunicatorComponent

#del, #initialize

Constructor Details

This class inherits a constructor from AcpcTableManager::CommunicatorComponent

Instance Method Details

#subscribe_with_timeout ⇒ Object 



51
52
53
54
55
56
57
58
59
60
61
 
# File 'lib/acpc_table_manager.rb', line 51

def subscribe_with_timeout
  list, message = @redis.blpop(
    @channel,
    timeout: AcpcTableManager.config.maintenance_interval_s
  )
  if message
    yield JSON.parse(message)
  else
    raise SubscribeTimeout
  end
end