validateParameter(Object, String, String) | | 25% | | 50% | 4 | 5 | 4 | 8 | 0 | 1 |
updateDisposition(String, String, DispositionStatus, Map, String, String, ServiceBusTransactionContext) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
lambda$updateDisposition$4(String, String, DispositionStatus, String, String, Map, ServiceBusTransactionContext) | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
lambda$getActiveLink$10(Retry.RetrySignal) | | 63% | | 37% | 4 | 5 | 5 | 12 | 0 | 1 |
lambda$getSessionState$1(String, ServiceBusManagementNode) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
getLinkName(String) | | 0% | | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
getSessionState(String) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getErrorContext() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
onSessionRequest(long) | | 92% | | 75% | 2 | 5 | 2 | 13 | 0 | 1 |
close() | | 96% | | 75% | 1 | 3 | 1 | 8 | 0 | 1 |
lambda$renewSessionLock$3(String, ServiceBusManagementNode) | | 95% | | 50% | 1 | 2 | 0 | 3 | 0 | 1 |
lambda$getActiveLink$7(AmqpEndpointState) | | 85% | | 50% | 1 | 2 | 0 | 1 | 0 | 1 |
ServiceBusSessionManager(String, MessagingEntityType, ServiceBusConnectionProcessor, TracerProvider, MessageSerializer, ReceiverOptions, ServiceBusReceiveLink) | | 100% | | 100% | 0 | 2 | 0 | 26 | 0 | 1 |
receive() | | 100% | | 100% | 0 | 3 | 0 | 6 | 0 | 1 |
lambda$getSession$12(ServiceBusReceiveLink, boolean, Scheduler, String, ServiceBusSessionReceiver) | | 100% | | 100% | 0 | 2 | 0 | 4 | 0 | 1 |
createSessionReceiveLink() | | 100% | | 100% | 0 | 2 | 0 | 6 | 0 | 1 |
lambda$getSession$15(Scheduler, SignalType) | | 100% | | 100% | 0 | 2 | 0 | 5 | 0 | 1 |
getActiveLink() | | 100% | | 100% | 0 | 2 | 0 | 4 | 0 | 1 |
getSession(Scheduler, boolean) | | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
renewSessionLock(String) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
lambda$createSessionReceiveLink$6(String, String, ServiceBusAmqpConnection) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$new$0(int) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$getSession$13(ServiceBusReceiveLink, boolean, Scheduler, String) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$getActiveLink$8(ServiceBusReceiveLink) | | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
ServiceBusSessionManager(String, MessagingEntityType, ServiceBusConnectionProcessor, TracerProvider, MessageSerializer, ReceiverOptions) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
lambda$getSession$14(boolean, Scheduler, ServiceBusReceiveLink) | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
lambda$renewSessionLock$2(ServiceBusSessionReceiver, OffsetDateTime, SynchronousSink) | | 100% | | 50% | 1 | 2 | 0 | 4 | 0 | 1 |
lambda$getManagementNode$17(ServiceBusAmqpConnection) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$getSession$16(Scheduler, ServiceBusSessionReceiver) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getManagementNode() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$getActiveLink$9() | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
lambda$getActiveLink$11(Flux) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
static {...} | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$close$5(ServiceBusSessionReceiver) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |