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