queueWork(int, Duration, FluxSink) | | 77% | | 50% | 3 | 4 | 5 | 17 | 0 | 1 |
close() | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
receiveMessages(int, Duration) | | 75% | | 75% | 2 | 5 | 1 | 8 | 0 | 1 |
peekMessages(int, long, String) | | 57% | | 50% | 1 | 2 | 1 | 6 | 0 | 1 |
peekMessages(int, String) | | 55% | | 50% | 1 | 2 | 1 | 6 | 0 | 1 |
lambda$renewSessionLock$6(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$renewSessionLock$5(String, Void) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$renewMessageLock$3(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$renewMessageLock$2(String, Void) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
commitTransaction(ServiceBusTransactionContext) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
rollbackTransaction(ServiceBusTransactionContext) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
createTransaction() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
renewMessageLock(ServiceBusReceivedMessage, Duration, Consumer) | | 96% | | 75% | 1 | 3 | 0 | 6 | 0 | 1 |
ServiceBusReceiverClient(ServiceBusReceiverAsyncClient, Duration) | | 100% | | n/a | 0 | 1 | 0 | 7 | 0 | 1 |
renewSessionLock(String, Duration, Consumer) | | 100% | | 100% | 0 | 2 | 0 | 5 | 0 | 1 |
receiveDeferredMessageBatch(Iterable, String) | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
lambda$renewSessionLock$4(String, Throwable) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$renewMessageLock$1(String, Throwable) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
abandon(ServiceBusReceivedMessage, AbandonOptions) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
complete(ServiceBusReceivedMessage, CompleteOptions) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
defer(ServiceBusReceivedMessage, DeferOptions) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
deadLetter(ServiceBusReceivedMessage, DeadLetterOptions) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
peekMessage(long, String) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
receiveDeferredMessage(long, String) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
setSessionState(String, byte[]) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
abandon(ServiceBusReceivedMessage) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
complete(ServiceBusReceivedMessage) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
defer(ServiceBusReceivedMessage) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
deadLetter(ServiceBusReceivedMessage) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
peekMessage(String) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
peekMessages(int, long) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
renewMessageLock(ServiceBusReceivedMessage) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
renewSessionLock(Duration, Consumer) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
renewSessionLock(String) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getSessionState(String) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
peekMessage(long) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
peekMessages(int) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
receiveDeferredMessage(long) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
receiveDeferredMessageBatch(Iterable) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
setSessionState(byte[]) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
getSessionState() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
peekMessage() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
renewSessionLock() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
receiveMessages(int) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$receiveMessages$0(int, Duration, FluxSink) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getFullyQualifiedNamespace() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getEntityPath() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |