29 added classes/operations | |||
![]() |
A | LimitReachedException added | |
![]() |
A | MemoryLimiter added | |
![]() |
A | MessagesLimiter added | |
![]() |
A | TimeLimiter added | |
![]() |
A | QueueConsumeCommand::getConsumerTag() added | |
![]() |
A | Consumer::onConsumeMessage() added | |
![]() |
B | Consumer::onMessageConsumed() added | |
![]() |
A | Consumer::onConsumeException() added | |
![]() |
A | Consumer::getPayloadOutput() added | |
![]() |
A | Consumer::flush() added | |
C | ↗ | B | QueueConsumeCommand::execute() improved |
view all |
Head | |
---|---|
⋮ | 4 more commits |
Base | |