123456789_123456789_123456789_123456789_123456789_

Class: ActionCable::SubscriptionAdapter::Redis

Do not use. This class is for internal use only.
Relationships & Source Files
Namespace Children
Classes:
Listener
Super Chains via Extension / Inclusion / Inheritance
Class Chain:
self, Base
Instance Chain:
self, ChannelPrefix, Base
Inherits: ActionCable::SubscriptionAdapter::Base
Defined in: actioncable/lib/action_cable/subscription_adapter/redis.rb

Class Attribute Summary

  • .redis_connector (also: #redis_connector) rw

    Overwrite this factory method for Redis connections if you want to use a different Redis library than the redis gem.

Class Method Summary

Base - Inherited

.new

Instance Attribute Summary

Base - Inherited

#logger, #server

Instance Method Summary

ChannelPrefix - Included

#broadcast, #subscribe, #unsubscribe,
#channel_with_prefix

Returns the channel name, including channel_prefix specified in cable.yml.

Base - Inherited

#broadcast, #identifier, #shutdown, #subscribe, #unsubscribe

Constructor Details

.new ⇒ Redis

[ GitHub ] 

  


# File 'actioncable/lib/action_cable/subscription_adapter/redis.rb', line 19



def initialize(*)
  super
  @listener = nil
  @redis_connection_for_broadcasts = nil
end


  







Class Attribute Details



  

    .redis_connector   (rw)
    Also known as: #redis_connector
  



  

    

Overwrite this factory method for Redis connections if you want to use a different Redis library than the redis gem. This is needed, for example, when using Makara proxies for distributed Redis.


  



  [ GitHub ]


  

  


# File 'actioncable/lib/action_cable/subscription_adapter/redis.rb', line 15



cattr_accessor :redis_connector, default: ->(config) do
  ::Redis.new(config.except(:adapter, :channel_prefix))
end


  







Instance Attribute Details



  

    #redis_connector   (rw)
  

  [ GitHub ]


  

  


# File 'actioncable/lib/action_cable/subscription_adapter/redis.rb', line 15



cattr_accessor :redis_connector, default: ->(config) do
  ::Redis.new(config.except(:adapter, :channel_prefix))
end


  







Instance Method Details



  

    #broadcast(channel, payload)  
  

  [ GitHub ]


  

  


# File 'actioncable/lib/action_cable/subscription_adapter/redis.rb', line 25



def broadcast(channel, payload)
  redis_connection_for_broadcasts.publish(channel, payload)
end


  








  

    #config_options   (private)
  

  [ GitHub ]


  

  


# File 'actioncable/lib/action_cable/subscription_adapter/redis.rb', line 60



def config_options
  @config_options ||= @server.config.cable.deep_symbolize_keys.merge(id: identifier)
end


  








  

    #listener   (private)
  

  [ GitHub ]


  

  


# File 'actioncable/lib/action_cable/subscription_adapter/redis.rb', line 46



def listener
  @listener || @server.mutex.synchronize { @listener ||= Listener.new(self, config_options, @server.event_loop) }
end


  








  

    #redis_connection   (private)
  

  [ GitHub ]


  

  


# File 'actioncable/lib/action_cable/subscription_adapter/redis.rb', line 56



def redis_connection
  self.class.redis_connector.call(config_options)
end


  








  

    #redis_connection_for_broadcasts   (private)
  

  [ GitHub ]


  

  


# File 'actioncable/lib/action_cable/subscription_adapter/redis.rb', line 50



def redis_connection_for_broadcasts
  @redis_connection_for_broadcasts || @server.mutex.synchronize do
    @redis_connection_for_broadcasts ||= redis_connection
  end
end


  








  

    #redis_connection_for_subscriptions  
  

  [ GitHub ]


  

  


# File 'actioncable/lib/action_cable/subscription_adapter/redis.rb', line 41



def redis_connection_for_subscriptions
  redis_connection
end


  








  

    #shutdown  
  

  [ GitHub ]


  

  


# File 'actioncable/lib/action_cable/subscription_adapter/redis.rb', line 37



def shutdown
  @listener.shutdown if @listener
end


  








  

    #subscribe(channel, callback, success_callback = nil)  
  

  [ GitHub ]


  

  


# File 'actioncable/lib/action_cable/subscription_adapter/redis.rb', line 29



def subscribe(channel, callback, success_callback = nil)
  listener.add_subscriber(channel, callback, success_callback)
end


  








  

    #unsubscribe(channel, callback)  
  

  [ GitHub ]


  

  


# File 'actioncable/lib/action_cable/subscription_adapter/redis.rb', line 33



def unsubscribe(channel, callback)
  listener.remove_subscriber(channel, callback)
end