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