module Backrub
Constants
- VERSION
Attributes
store[W]
Public Instance Methods
publish(channel, message)
click to toggle source
# File lib/backrub.rb, line 23 def publish(channel, message) store.publish(channel, message) end
store()
click to toggle source
# File lib/backrub.rb, line 9 def store @store ||= Backrub::Store::Redis.new end
subscribe(channels_with_backlog, &block)
click to toggle source
# File lib/backrub.rb, line 13 def subscribe(channels_with_backlog, &block) channels_with_backlog.each do |channel, count| store.backlog(channel.to_s, count.to_i, &block) unless count.zero? end channels = channels_with_backlog.keys.map(&:to_s) store.subscribe(*channels, &block) end