treehouselabs /
queue-bundle
547 +26 Covered Lines
846 +23 Total Lines
64.7 % +1.4% Code Coverage
|
|
⇢ |
0%
|
Consumer added |
|
|
⇢ |
100%
|
LimitReachedException added |
|
|
⇢ |
100%
|
MemoryLimiter added |
|
|
⇢ |
100%
|
MessagesLimiter added |
|
|
⇢ |
100%
|
TimeLimiter added |
|
|
⇢ |
20
|
Consumer::onMessageConsumed() added |
|
|
⇢ |
12
|
Consumer::getPayloadOutput() added |
|
|
⇢ |
6
|
Consumer::consume() added |
|
|
⇢ |
6
|
Consumer::shutdown() added |
|
|
⇢ |
2
|
Consumer::getProcessed() added |
|
|
⇢ |
2
|
Consumer::getStartTime() added |
|
|
⇢ |
2
|
QueueConsumeCommand::getConsumerTag() added |
|
|
⇢ |
2
|
Consumer::getDuration() added |
|
|
⇢ |
2
|
Consumer::onConsumeMessage() added |
|
|
⇢ |
2
|
MemoryLimiter::limitReached() added |
| ⋮ | view more | ||
|
20
|
↛ |
|
QueueConsumeCommand::getPayloadOutput() removed |
|
6
|
↛ |
|
QueueConsumeCommand::output() removed |
|
6
|
↛ |
|
QueueConsumeCommand::shutdown() removed |
|
2
|
↛ |
|
QueueConsumeCommand::onConsumeMessage() removed |
|
2
|
↛ |
|
QueueConsumeCommand::onMessageConsumed() removed |
|
2
|
↛ |
|
QueueConsumeCommand::onConsumeException() removed |
|
2
|
↛ |
|
QueueConsumeCommand::getConsumer() removed |
|
2
|
↛ |
|
QueueConsumeCommand::flush() removed |
