Redis Support

Ecotone support for Redis


composer require ecotone/redis

Module Powered By

Enqueue solid and powerful abstraction over asynchronous queues.


In order to use Redis Support we need to add ConnectionFactory to our Dependency Container.

# config/services.yaml
    class: Enqueue\Redis\RedisConnectionFactory
        - "redis://localhost:6379"

We register our RedisConnectionFactory under the class name Enqueue\Redis\RedisConnectionFactory. This will help Ecotone resolve it automatically, without any additional configuration.

Message Channel

To create Message Channel, we need to create Service Context.

use Ecotone\Redis\RedisBackedMessageChannelBuilder;

class MessagingConfiguration
    public function orderChannel()
        return RedisBackedMessageChannelBuilder::create("orders");

Now orders channel will be available in Messaging System.

Message Channel Configuration

    ->withAutoDeclare(false) // do not auto declare queue
    ->withDefaultTimeToLive(1000) // limit TTL of messages

Message Publisher

If you want to publish Message directly to Exchange, you may use of Publisher.

use Ecotone\Redis\Configuration\RedisMessageConsumerConfiguration;

class PublisherConfiguration
    public function registerPublisherConfig()
                MessagePublisher::class, // 1
                "delivery", // 2
                "application/json" // 3
  1. Reference name - Name under which it will be available in Dependency Container.

  2. Queue name - Name of queue where Message should be published

  3. Default Conversion [Optional] - Default type, payload will be converted to.

Publisher Configuration

RedisMessagePublisherConfiguration::create(queueName: $queueName)
    ->withAutoDeclareQueueOnSend(false) // 1
    ->withHeaderMapper("application.*") // 2
  1. withAutoDeclareQueueOnSend - should Ecotone try to declare queue before sending message

  2. withHeaderMapper - On default headers are not send with message. You map provide mapping for headers that should be mapped to Redis Message

Message Consumer

To connect consumer directly to a Redis Queue, we need to provide Ecotone with information, how the Queue is configured.

use Ecotone\Redis\Configuration\RedisMessageConsumerConfiguration;

class ConsumerConfiguration
    public function registerConsumerConfig(): array
        return [
            RedisMessageConsumerConfiguration::create("orders_consumer", "orders")
  1. Provides Consumer that will be registered at given name "orders_consumer" and will be polling "orders" queue

Consumer Configuration

$consumerConfiguration = RedisMessageConsumerConfiguration::createDirectExchange
                ->withDeclareOnStartup(false) // do not try to declare queue before consuming first message;

Last updated