Class: ActiveOrm::Redis::PubSub
Instance Attribute Summary
#client
Attributes inherited from Base
#configuration
Class Method Summary
collapse
client, #initialize
Methods included from Base
#evaluate, #evaluate?
Methods inherited from Base
configuration, configuration=, configure
Class Method Details
.match_subscribe(*channels, &block) ⇒ Object
19
20
21
|
# File 'lib/active_orm/redis/pub_sub.rb', line 19
def self.match_subscribe(*channels, &block)
client.psubscribe(channels, &block)
end
|
.match_unsubscribe(*channels) ⇒ Object
23
24
25
|
# File 'lib/active_orm/redis/pub_sub.rb', line 23
def self.match_unsubscribe(*channels)
client.punsubscribe(channels)
end
|
.publish(channel, message) ⇒ Object
3
4
5
|
# File 'lib/active_orm/redis/pub_sub.rb', line 3
def self.publish(channel, message)
client.publish(channel, message)
end
|
.state(command, *args) ⇒ Object
27
28
29
|
# File 'lib/active_orm/redis/pub_sub.rb', line 27
def self.state(command, *args)
client.pubsub(command, args)
end
|
.subscribe(*channels, &block) ⇒ Object
11
12
13
|
# File 'lib/active_orm/redis/pub_sub.rb', line 11
def self.subscribe(*channels, &block)
client.subscribe(channels, &block)
end
|
.subscribed? ⇒ Boolean
7
8
9
|
# File 'lib/active_orm/redis/pub_sub.rb', line 7
def self.subscribed?
client.subscribed?
end
|
.unsubscribe(*channels) ⇒ Object
15
16
17
|
# File 'lib/active_orm/redis/pub_sub.rb', line 15
def self.unsubscribe(*channels)
client.unsubscribe(channels)
end
|