Module: MessageBusClient::MessageHandler

Included in:
Client
Defined in:
lib/message_bus_client/message_handler.rb

Defined Under Namespace

Classes: SubscribedChannel

Constant Summary collapse

CHUNK_SEPARATOR =

The chunk separator for chunked messages.

"\r\n|\r\n"

Instance Method Summary collapse

Instance Method Details

#initialize(base_url) ⇒ Object 



18
19
20
21
22
23
24
 
# File 'lib/message_bus_client/message_handler.rb', line 18

def initialize(base_url)
  super

  @pending_messages = []
  @subscribed_channels = {}
  @payload = String.new
end

#subscribe(channel, last_id = -1,, &callback) ⇒ Object 



26
27
28
29
30
31
32
33
 
# File 'lib/message_bus_client/message_handler.rb', line 26

def subscribe(channel, last_id=-1, &callback)
  subscribed_channel = @subscribed_channels[channel]
  if subscribed_channel.nil?
    subscribed_channel = @subscribed_channels[channel] =
      SubscribedChannel.new(last_id)
  end
  subscribed_channel.callbacks << callback
end

#unsubscribe ⇒ Object 



35
36
 
# File 'lib/message_bus_client/message_handler.rb', line 35

def unsubscribe
end