Method: MessageBus::ConnectionManager#subscribe_client

Defined in:
lib/message_bus/connection_manager.rb

#subscribe_client(client, channel) ⇒ Object 



83
84
85
86
87
88
89
90
91
92
 
# File 'lib/message_bus/connection_manager.rb', line 83

def subscribe_client(client, channel)
  synchronize do
    set = @subscriptions[client.site_id][channel]
    unless set
      set = Set.new
      @subscriptions[client.site_id][channel] = set
    end
    set << client.client_id
  end
end