Class: Volt::MessageBus::BaseMessageBus

Inherits:
Object
  • Object
show all
Defined in:
lib/volt/server/message_bus/base_message_bus.rb

Direct Known Subclasses

PeerToPeer

Instance Method Summary collapse

Constructor Details

#initialize(volt_app) ⇒ BaseMessageBus

MessagesBus’s should take an instance of a Volt::App



36
37
38
 
# File 'lib/volt/server/message_bus/base_message_bus.rb', line 36

def initialize(volt_app)
  raise "Not implemented"
end

Instance Method Details

#disconnect! ⇒ Object

waits for all messages to be flushed and closes connections



52
53
54
 
# File 'lib/volt/server/message_bus/base_message_bus.rb', line 52

def disconnect!
  raise "Not implemented"
end

#publish(channel_name, message) ⇒ Object

publish should push out to all subscribed within the volt cluster.



47
48
49
 
# File 'lib/volt/server/message_bus/base_message_bus.rb', line 47

def publish(channel_name, message)
  raise "Not implemented"
end

#subscribe(channel_name, &block) ⇒ Object

Subscribe should return an object that you can call .remove on to stop the subscription.



42
43
44
 
# File 'lib/volt/server/message_bus/base_message_bus.rb', line 42

def subscribe(channel_name, &block)
  raise "Not implemented"
end