class ActionCable::SubscriptionAdapter::Redis

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

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

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

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

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

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

def redis_connection_for_subscriptions
  redis_connection
end

def shutdown
  @listener.shutdown if @listener
end

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

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