- Added support
psr/container
with version>=1.1.0
.
- Added new configuration parameters:
connection_timeout
,read_write_timeout
,heartbeat
.
- Change exception logging in
ConsumerRunCommand
.
- [BC BREAK] Constants moved from
ConsumerInterface
toAbstractConsumer
.
- Changed return value usage from using Command::SUCCESS constant to scalar.
- Commands changed:
- UpdateDefinitionCommand
- ConsumerListCommand
- ConsumerRunCommand
- Added retry exchange for rewind message in queue with delay.
- Added config parameters
idle_timeout
andwait_timeout
. - Added publishers:
FifoPublisher
,DelayPublisher
,FifoPublisher
,DeduplicatePublisher
,DeduplicateDelayPublisher
.
- Optimized receiving a batch of messages in
ConsumerRunCommand
. - Extended supported queue types by
Delay
,Deduplicate
.
- Fix rewind and release partial messages by delivery tag. Changed
ReleasePartialException
,RewindDelayPartialException
,RewindPartialException
.
- Change license type.
- The first basic version of the bundle.