renewMessageLock(ServiceBusReceivedMessage, Duration) | | 54% | | 64% | 5 | 8 | 7 | 20 | 0 | 1 |
commitTransaction(ServiceBusTransactionContext) | | 0% | | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
rollbackTransaction(ServiceBusTransactionContext) | | 0% | | 0% | 4 | 4 | 10 | 10 | 1 | 1 |
updateDisposition(ServiceBusReceivedMessage, DispositionStatus, String, String, Map, ServiceBusTransactionContext) | | 78% | | 75% | 5 | 11 | 5 | 33 | 0 | 1 |
renewSessionLock(String, Duration) | | 60% | | 66% | 4 | 7 | 5 | 17 | 0 | 1 |
renewMessageLock(ServiceBusReceivedMessage) | | 48% | | 60% | 4 | 6 | 5 | 14 | 0 | 1 |
createTransaction() | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
lambda$new$1(LockRenewalOperation) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
getSessionState(String) | | 61% | | 66% | 2 | 4 | 3 | 11 | 0 | 1 |
setSessionState(String, byte[]) | | 63% | | 66% | 2 | 4 | 3 | 12 | 0 | 1 |
renewSessionLock(String) | | 62% | | 66% | 2 | 4 | 3 | 12 | 0 | 1 |
abandon(ServiceBusReceivedMessage, AbandonOptions) | | 51% | | 50% | 3 | 4 | 3 | 7 | 0 | 1 |
defer(ServiceBusReceivedMessage, DeferOptions) | | 51% | | 50% | 3 | 4 | 3 | 7 | 0 | 1 |
complete(ServiceBusReceivedMessage, CompleteOptions) | | 52% | | 50% | 3 | 4 | 3 | 7 | 0 | 1 |
lambda$receiveDeferredMessage$21(ServiceBusReceivedMessage) | | 25% | | 25% | 2 | 3 | 5 | 7 | 0 | 1 |
lambda$updateDisposition$41(ServiceBusReceivedMessage, String, Mono, Boolean) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
close() | | 73% | | 75% | 2 | 5 | 4 | 18 | 0 | 1 |
receiveDeferredMessage(long, String) | | 54% | | 50% | 1 | 2 | 2 | 7 | 0 | 1 |
receiveDeferredMessages(Iterable, String) | | 54% | | 50% | 1 | 2 | 2 | 7 | 0 | 1 |
renewMessageLock(String) | | 54% | | 50% | 1 | 2 | 2 | 7 | 0 | 1 |
peekMessage(String) | | 53% | | 50% | 1 | 2 | 2 | 7 | 0 | 1 |
peekMessages(int, long, String) | | 51% | | 50% | 1 | 2 | 2 | 6 | 0 | 1 |
peekMessage(long, String) | | 50% | | 50% | 1 | 2 | 2 | 6 | 0 | 1 |
peekMessages(int, String) | | 50% | | 50% | 1 | 2 | 2 | 6 | 0 | 1 |
receiveDeferredMessage(long) | | 42% | | 50% | 1 | 2 | 2 | 4 | 0 | 1 |
receiveMessages() | | 40% | | 50% | 1 | 2 | 2 | 4 | 0 | 1 |
receiveMessagesWithContext(int) | | 79% | | 87% | 1 | 5 | 1 | 13 | 0 | 1 |
getLinkName(String) | | 59% | | 50% | 4 | 6 | 2 | 6 | 0 | 1 |
lambda$receiveMessagesWithContext$17(ServiceBusMessageContext) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
getOrCreateConsumer() | | 89% | | 50% | 2 | 3 | 3 | 17 | 0 | 1 |
deadLetter(ServiceBusReceivedMessage, DeadLetterOptions) | | 80% | | 66% | 2 | 4 | 1 | 8 | 0 | 1 |
lambda$updateDisposition$43(DispositionStatus, Throwable) | | 71% | | 60% | 2 | 4 | 2 | 6 | 0 | 1 |
lambda$rollbackTransaction$37(ServiceBusTransactionContext, AmqpSession) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$commitTransaction$35(ServiceBusTransactionContext, AmqpSession) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
renewSessionLock(Duration) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
setSessionState(byte[]) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getSessionState() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
renewSessionLock() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$createTransaction$33(AmqpTransaction) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$receiveMessagesNoBackPressure$15(ServiceBusMessageContext, SynchronousSink) | | 61% | | 50% | 1 | 2 | 2 | 5 | 0 | 1 |
lambda$getSessionState$55(Throwable) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$setSessionState$52(Throwable) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$renewSessionLock$49(Throwable) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isConnectionClosed() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$rollbackTransaction$36(ServiceBusAmqpConnection) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$commitTransaction$34(ServiceBusAmqpConnection) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$createTransaction$31(ServiceBusAmqpConnection) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getReceiverOptions() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$createTransaction$32(AmqpSession) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$receiveMessagesWithContext$16(ServiceBusMessageContext) | | 90% | | 50% | 1 | 2 | 0 | 1 | 0 | 1 |
ServiceBusReceiverAsyncClient(String, String, MessagingEntityType, ReceiverOptions, ServiceBusConnectionProcessor, Duration, TracerProvider, MessageSerializer, Runnable, ServiceBusSessionManager) | | 100% | | n/a | 0 | 1 | 0 | 18 | 0 | 1 |
ServiceBusReceiverAsyncClient(String, String, MessagingEntityType, ReceiverOptions, ServiceBusConnectionProcessor, Duration, TracerProvider, MessageSerializer, Runnable) | | 100% | | n/a | 0 | 1 | 0 | 18 | 0 | 1 |
lambda$peekMessages$12(String, int, ServiceBusManagementNode) | | 100% | | n/a | 0 | 1 | 0 | 9 | 0 | 1 |
lambda$getOrCreateConsumer$45(ServiceBusReceiveLink) | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
lambda$getOrCreateConsumer$44(String, ServiceBusAmqpConnection) | | 100% | | 100% | 0 | 2 | 0 | 4 | 0 | 1 |
lambda$updateDisposition$40(DispositionStatus, String, ServiceBusReceivedMessage) | | 100% | | n/a | 0 | 1 | 0 | 5 | 0 | 1 |
lambda$updateDisposition$42(DispositionStatus, String, ServiceBusReceivedMessage) | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
lambda$peekMessage$3(String, ServiceBusManagementNode) | | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
lambda$receiveDeferredMessages$24(ServiceBusReceivedMessage) | | 100% | | 75% | 1 | 3 | 0 | 7 | 0 | 1 |
lambda$new$0(LockRenewalOperation) | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
lambda$peekMessage$5(ServiceBusReceivedMessage, SynchronousSink) | | 100% | | n/a | 0 | 1 | 0 | 5 | 0 | 1 |
lambda$peekMessages$11(ServiceBusReceivedMessage, SynchronousSink) | | 100% | | n/a | 0 | 1 | 0 | 5 | 0 | 1 |
lambda$receiveDeferredMessage$20(String, long, ServiceBusManagementNode) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
lambda$peekMessages$9() | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
lambda$updateDisposition$39(String, DispositionStatus, String, String, Map, String, ServiceBusTransactionContext, ServiceBusManagementNode) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
mapError(Throwable, ServiceBusErrorSource) | | 100% | | 100% | 0 | 2 | 0 | 3 | 0 | 1 |
lambda$receiveDeferredMessages$23(String, Iterable, ServiceBusManagementNode) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
abandon(ServiceBusReceivedMessage) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
complete(ServiceBusReceivedMessage) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
defer(ServiceBusReceivedMessage) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$peekMessages$14(long, String, int, ServiceBusManagementNode) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
peekMessages(int, long) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$peekMessage$7(long, String, ServiceBusManagementNode) | | 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 |
receiveDeferredMessages(Iterable) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$getSessionState$54(String, ServiceBusManagementNode) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$getSessionState$53(ServiceBusAmqpConnection) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$setSessionState$50(ServiceBusAmqpConnection) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$renewSessionLock$46(ServiceBusAmqpConnection) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$updateDisposition$38(ServiceBusAmqpConnection) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$renewMessageLock$28(String, OffsetDateTime) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$renewMessageLock$27(String, ServiceBusManagementNode) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$renewMessageLock$26(ServiceBusAmqpConnection) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$receiveDeferredMessages$22(ServiceBusAmqpConnection) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$receiveDeferredMessage$19(ServiceBusAmqpConnection) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$peekMessages$13(ServiceBusAmqpConnection) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$peekMessages$8(ServiceBusAmqpConnection) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$peekMessage$6(ServiceBusAmqpConnection) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$peekMessage$2(ServiceBusAmqpConnection) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
peekMessage() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
receiveMessagesNoBackPressure() | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
lambda$setSessionState$51(String, byte[], String, ServiceBusManagementNode) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
deadLetter(ServiceBusReceivedMessage) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
isManagementToken(String) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$renewSessionLock$48(Throwable) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$renewSessionLock$47(String, String, ServiceBusManagementNode) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$renewMessageLock$30(Throwable) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$renewMessageLock$25(Throwable) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$receiveMessagesWithContext$18(Throwable) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$peekMessages$10(ServiceBusReceivedMessage, long) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$peekMessage$4(ServiceBusReceivedMessage, long) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
static {...} | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
receiveMessagesWithContext() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
isManagementNodeLocksClosed() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
isRenewalContainerClosed() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$renewMessageLock$29(ServiceBusReceivedMessage, String) | | 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 |