Sha256: 68d979179b517b8ac625b4ea54dfb22e94ceba208cdb4c242d6359ac920464e5
Contents?: true
Size: 595 Bytes
Versions: 8
Compression:
Stored size: 595 Bytes
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
8 entries across 8 versions & 1 rubygems