class Volt::MessageBus::BaseMessageBus
Public Class Methods
new(volt_app)
click to toggle source
MessagesBus's should take an instance of a Volt::App
# File lib/volt/server/message_bus/base_message_bus.rb, line 36 def initialize(volt_app) raise "Not implemented" end
Public Instance Methods
disconnect!()
click to toggle source
waits for all messages to be flushed and closes connections
# File lib/volt/server/message_bus/base_message_bus.rb, line 52 def disconnect! raise "Not implemented" end
publish(channel_name, message)
click to toggle source
publish should push out to all subscribed within the volt cluster.
# 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)
click to toggle source
Subscribe should return an object that you can call .remove on to stop the subscription.
# File lib/volt/server/message_bus/base_message_bus.rb, line 42 def subscribe(channel_name, &block) raise "Not implemented" end