Contents

# frozen_string_literal: true

gem "redis", ">= 3"

require "redis"
require "json"

module AnyCable
  module BroadcastAdapters
    # Redis adapter for broadcasting.
    #
    # Example:
    #
    #   AnyCable.broadast_adapter = :redis
    #
    # It uses Redis configuration from global AnyCable config
    # by default.
    #
    # You can override these params:
    #
    #   AnyCable.broadcast_adapter = :redis, url: "redis://my_redis", channel: "_any_cable_"
    class Redis < Base
      attr_reader :redis_conn, :channel

      def initialize(
        channel: AnyCable.config.redis_channel,
        **options
      )
        options = AnyCable.config.to_redis_params.merge(options)
        @redis_conn = ::Redis.new(options)
        @channel = channel
      end

      def raw_broadcast(payload)
        redis_conn.publish(channel, payload)
      end

      def announce!
        logger.info "Broadcasting Redis channel: #{channel}"
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
anycable-1.0.3	lib/anycable/broadcast_adapters/redis.rb
anycable-1.0.2	lib/anycable/broadcast_adapters/redis.rb
anycable-1.0.1	lib/anycable/broadcast_adapters/redis.rb
anycable-1.0.0	lib/anycable/broadcast_adapters/redis.rb
anycable-1.0.0.rc2	lib/anycable/broadcast_adapters/redis.rb
anycable-1.0.0.rc1	lib/anycable/broadcast_adapters/redis.rb