Class: ActiveOrm::Redis::PubSub

Inherits:
ActiveOrm::Redis show all
Defined in:
lib/active_orm/redis/pub_sub.rb

Instance Attribute Summary

Attributes inherited from ActiveOrm::Redis

#client

Attributes inherited from Base

#configuration

Class Method Summary collapse

Methods inherited from ActiveOrm::Redis

client, #initialize

Methods included from Base

#evaluate, #evaluate?

Methods inherited from Base

configuration, configuration=, configure

Constructor Details

This class inherits a constructor from ActiveOrm::Redis

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

Returns:

  • (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