lambda$schedule$13(List, OffsetDateTime, int, String, ServiceBusTransactionContext, RequestResponseChannel) | | 0% | | 0% | 6 | 6 | 35 | 35 | 1 | 1 |
lambda$sendWithVerify$17(RequestResponseChannel, Message, SynchronousSink) | | 8% | | 10% | 5 | 6 | 21 | 24 | 0 | 1 |
lambda$receiveDeferredMessages$7(String, List, ServiceBusReceiveMode, String, RequestResponseChannel) | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
lambda$renewSessionLock$12(String, Message) | | 34% | | 50% | 2 | 3 | 4 | 10 | 0 | 1 |
lambda$peek$4(String, long, int, String, RequestResponseChannel) | | 0% | | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
lambda$renewMessageLock$10(String, Message) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
lambda$renewMessageLock$9(String, String, RequestResponseChannel) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
lambda$schedule$14(Message) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
lambda$cancelScheduledMessages$1(String, List, RequestResponseChannel) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
lambda$getSessionState$3(String, Message) | | 61% | | 75% | 1 | 3 | 2 | 11 | 0 | 1 |
receiveDeferredMessages(ServiceBusReceiveMode, String, String, Iterable) | | 57% | | 75% | 1 | 3 | 3 | 9 | 0 | 1 |
peek(long, String, String, int) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
cancelScheduledMessages(Iterable, String) | | 50% | | 50% | 1 | 2 | 3 | 7 | 0 | 1 |
mapError(Throwable) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
close() | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
lambda$receiveDeferredMessages$8(Message) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$peek$5(Message) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
peek(long, String, String) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$updateDisposition$16(UUID[], DispositionStatus, String, String, String, String, Map, ServiceBusTransactionContext, RequestResponseChannel) | | 95% | | 64% | 5 | 8 | 1 | 20 | 0 | 1 |
lambda$receiveDeferredMessages$6(List, Long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$cancelScheduledMessages$0(List, Long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
ManagementChannel(Mono, String, String, TokenManager, MessageSerializer, Duration) | | 100% | | n/a | 0 | 1 | 0 | 9 | 0 | 1 |
lambda$isAuthorized$18(String, AmqpResponseCode, SynchronousSink) | | 100% | | 75% | 1 | 3 | 0 | 8 | 0 | 1 |
lambda$setSessionState$15(String, String, byte[], RequestResponseChannel) | | 100% | | 100% | 0 | 2 | 0 | 6 | 0 | 1 |
createManagementMessage(String, String) | | 100% | | 50% | 1 | 2 | 0 | 9 | 0 | 1 |
getSessionState(String, String) | | 100% | | 100% | 0 | 3 | 0 | 6 | 0 | 1 |
renewSessionLock(String, String) | | 100% | | 100% | 0 | 3 | 0 | 6 | 0 | 1 |
setSessionState(String, byte[], String) | | 100% | | 100% | 0 | 3 | 0 | 5 | 0 | 1 |
updateDisposition(String, DispositionStatus, String, String, Map, String, String, ServiceBusTransactionContext) | | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
lambda$renewSessionLock$11(String, String, RequestResponseChannel) | | 100% | | n/a | 0 | 1 | 0 | 5 | 0 | 1 |
lambda$getSessionState$2(String, String, RequestResponseChannel) | | 100% | | n/a | 0 | 1 | 0 | 5 | 0 | 1 |
sendWithVerify(RequestResponseChannel, Message, DeliveryState) | | 100% | | n/a | 0 | 1 | 0 | 5 | 0 | 1 |
schedule(List, OffsetDateTime, int, String, ServiceBusTransactionContext) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
renewMessageLock(String, String) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
isAuthorized(String) | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
getErrorContext() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |