| ⇢ | A | Consumer added | |
| ⇢ | A | LimitReachedException added | |
| ⇢ | A | MemoryLimiter added | |
| ⇢ | A | MessagesLimiter added | |
| ⇢ | A | TimeLimiter added |
| ⇢ | B | Consumer::onMessageConsumed() added | |
| ⇢ | B | Consumer::shutdown() added | |
| ⇢ | A | Consumer::consume() added | |
| ⇢ | A | Consumer::__construct() added | |
| ⇢ | A | Consumer::getSubscribedEvents() added | |
| ⇢ | A | MemoryLimiter::limitReached() added | |
| ⇢ | A | Consumer::mustRunFor() added | |
| ⇢ | A | Consumer::flushAfter() added | |
| ⇢ | A | MessagesLimiter::limitReached() added | |
| ⇢ | A | Consumer::waitBetweenMessages() added | |
| ⋮ | view more | ||
| C | ↗ | B | QueueConsumeCommand::execute() improved |
| A | ↛ | QueueConsumeCommand::getPayloadOutput() removed | |
| A | ↛ | QueueConsumeCommand::shutdown() removed | |
| A | ↛ | QueueConsumeCommand::onConsumeMessage() removed | |
| A | ↛ | QueueConsumeCommand::onMessageConsumed() removed | |
| A | ↛ | QueueConsumeCommand::onConsumeException() removed | |
| A | ↛ | QueueConsumeCommand::output() removed | |
| A | ↛ | QueueConsumeCommand::getConsumer() removed | |
| A | ↛ | QueueConsumeCommand::flush() removed | |