- Add queue name to
ReceivedMessage
. - Add method
ReceivedMessage::isDirectPublisher
for check, is message direct published to queue (via default exchange).
- Add run checker for check any requirements before run consumer.
- Add
EventHandlers
for possible to use multiple event handlers.
- Add
EventableConsumerInterface
for control specific errors (consumer timeout, stop after N executes, etc...). - Add possible to shuffle spool connections.
- Add function for delete exchange and queue.
- Fix flush savepoint publisher for use multiple layers with commits/rollbacks.
- Require PHP 8.2 and higher.
- Message & ReceivedMessage classes - remove interfaces, remove getters. Please use classes and public properties for retrieve info.
- Add
FiveLab\Component\Amqp\Connection\Dsn
for collect all connection parameters. - Change connection factories for work with
Dsn
instead of array parameters. - Add
FiveLab\Component\Amqp\Connection\SpoolConnectionFactory::fromDsn
for possible create spool connection from DSN. - Add possible use
BackendEnum
as routing key for publish, bindings and arguments.
- Require php version:
>= 8.0
- Require symfony packages (dev requirements):
~5.4 | ~6.0
- Use lazy console commands.
- Add consumer registry based on Psr Container.
- Change constructor signature for
RoundRobinConsumer
(pass registry instead of list of consumers).
- Some bug fixes.
- Add support priority for message options.
??
??
- Remove support PHP 7.3 and early.
- Add support PHP 8.0.
- Fix Spool connection for possible use for all adapters.
Note: spool connection does not have backward compatibility. Class was be moved to
Connection
folder.
- Fix for support
Symfony 5
.
- Add support php-amqplib.
- Implement
MiddlewareAwareInterface
inLoggingConsumer
decorator.
- Disconnect after catch
StopAfterNExecutes
onsingle consumer
.
- Add option
--messages
to run consumer command.
- Add logging consumer.
- Add method for get count messages from queue.
- Add delay system (allow publish messages with delay).
- Add command for list possible consumers.
- Initialize amqp library.