Module: Slanger::Redis

Extended by:
Forwardable, Redis
Included in:
Redis
Defined in:
lib/slanger/redis.rb

Class Method Summary collapse

Class Method Details

.extended(base) ⇒ Object 



10
11
12
13
14
15
16
17
 
# File 'lib/slanger/redis.rb', line 10

def self.extended base
  # Dispatch messages received from Redis to their destination channel.
  base.on(:message) do |channel, message|
    message = JSON.parse message
    c = Channel.from message['channel']
    c.dispatch message, channel
  end
end