⇢ | A | LimitReachedException added | |
⇢ | A | MemoryLimiter added | |
⇢ | A | MessagesLimiter added | |
⇢ | A | TimeLimiter added | |
⇢ | A | Consumer added |
⇢ | B | Consumer::onMessageConsumed() added | |
⇢ | B | Consumer::shutdown() added | |
⇢ | A | Consumer::consume() added | |
⇢ | A | Consumer::onConsumeMessage() added | |
⇢ | A | MemoryLimiter::limitReached() added | |
⇢ | A | Consumer::onConsumeException() added | |
⇢ | A | MessagesLimiter::limitReached() added | |
⇢ | A | Consumer::getPayloadOutput() added | |
⇢ | A | TimeLimiter::limitReached() added | |
⇢ | A | Consumer::__construct() 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 |