Method: MessageBus::Client#subscribe

Defined in:
lib/message_bus/client.rb

#subscribe(channel, last_seen_id) ⇒ Object



38
39
40
41
42
# File 'lib/message_bus/client.rb', line 38

def subscribe(channel, last_seen_id)
  last_seen_id = nil if last_seen_id == ""
  last_seen_id ||= @bus.last_id(channel)
  @subscriptions[channel] = last_seen_id.to_i
end