Contents

class ActiveOrm::Redis::PubSub < ActiveOrm::Redis

  def self.publish(channel, message)
    client.publish(channel, message)
  end

  def self.subscribed?
    client.subscribed?
  end

  def self.subscribe(*channels, &block)
    client.subscribe(channels, &block)
  end

  def self.unsubscribe(*channels)
    client.unsubscribe(channels)
  end

  def self.match_subscribe(*channels, &block)
    client.psubscribe(channels, &block)
  end

  def self.match_unsubscribe(*channels)
    client.punsubscribe(channels)
  end

  def self.state(command, *args)
    client.pubsub(command, args)
  end

end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
active_orm-4.0.3	lib/active_orm/redis/pub_sub.rb
active_orm-4.0.2	lib/active_orm/redis/pub_sub.rb
active_orm-4.0.1	lib/active_orm/redis/pub_sub.rb
active_orm-4.0.0	lib/active_orm/redis/pub_sub.rb
active_orm-3.0.0	lib/active_orm/redis/pub_sub.rb