Tags

Tags give the ability to mark specific points in history as being important

  • v0.7.0

    0e1835aa · Fea: Обновил биндер для универсальности ·

  • v0.6.0

    6507ba34 · AAI-10810. Fix consumer ·

  • v0.5.0

    46f64db9 · AAI-10810. Remove final from dispatch method · 
    Remove final from dispatch method

  • v0.4.0

    22bca307 · AAI-11070. Add regul/observability packeage, add tests · 
    Add regul/observability package and traces

  • v0.3.0

    12a3cc93 · AAI-10810. Update AmqpConsumeManager · 
    Update AmqpConsumeManager. Add support for both types of config
```
'exchanges' => [
        'auth.events' => [
            'type' => AmqpExchangeTypes::Topic->value,
            'queues' => [
                'notify.auth.events' => [
                    'routing_key_pattern' => 'user.password_reset.initiated',
                    'user.password_reset.initiated' => PasswordResetInitiatedConsumer::class,
                ],
            ],
        ],
        'identity.events' => [
            'type' => AmqpExchangeTypes::Topic->value,
            'queues' => [
                'notify.identity.events' => [
                    'user.low_balance' => LowBalanceUserConsumer::class,
                    'user.password.updated' => UserPasswordUpdatedConsumer::class,
                    'user.created' => UserCreatedConsumer::class,
                    'user.created.promo' => UserCreatedConsumer::class,
                ],
            ],
        ],
    ]
```

```
'llm.streaming' => [
            'type' => AmqpExchangeTypes::Topic->value, // Используем topic exchange для поддержки wildcards
            'queues' => [
                'llm.chunks' => [
                    'routing_key_pattern' => '#.'.StreamQueue::Chunks->getRoutingKey(),
                    'consumer' => OnChunkConsumer::class,
                    'arguments' => [
                        'x-single-active-consumer' => true
                    ]
                ],
                'llm.finalize' => [
                    'routing_key_pattern' => '#.'.StreamQueue::Finalize->getRoutingKey(),
                    'consumer' => OnFinalizeConsumer::class,
                    'arguments' => [
                        'x-single-active-consumer' => true
                    ]
                ],
                'llm.errors' => [
                    'routing_key_pattern' => '#.'.StreamQueue::Errors->getRoutingKey(),
                    'consumer' => OnErrorConsumer::class,
                    'arguments' => [
                        'x-single-active-consumer' => true
                    ]
                ],
            ],
        ],
```

Both of them are valid

  • v0.2.0

    4a8c24c1 · AAI-10810. Fix AmqpBrokerService filename · 
    Rename file AqmpBrokerService to avoid error: Target class [Regul\Amqp\AmqpBrokerService] does not exist.

  • v0.1.0

    a827a44e · AAI-10810. Move amqp classes from service · 
    First version of package. Move classes from services, add dependencies, create composer.json