getSubscription(String, String, Map, Map, Symbol[], SenderSettleMode, ReceiverSettleMode, TokenManager) |  | 0% |  | 0% | 7 | 7 | 21 | 21 | 1 | 1 |
createConsumer(String, String, Duration, AmqpRetryPolicy, Map, Map, Symbol[], SenderSettleMode, ReceiverSettleMode) |  | 0% |  | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
getCoordinator(String, Duration, AmqpRetryPolicy) |  | 0% | | n/a | 1 | 1 | 12 | 12 | 1 | 1 |
createCoordinatorSendLink(Duration, AmqpRetryPolicy) |  | 0% |  | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
createTransactionCoordinator() |  | 0% |  | 0% | 3 | 3 | 8 | 8 | 1 | 1 |
lambda$createCoordinatorSendLink$8(Duration, AmqpRetryPolicy, MonoSink) |  | 0% |  | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
lambda$createTransactionCoordinator$6(AmqpSendLink) |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
lambda$createConsumer$14(String, TokenManager, String, Map, Map, Symbol[], SenderSettleMode, ReceiverSettleMode, String, ReactorSession.LinkSubscription) |  | 0% |  | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
lambda$getSubscription$25(String, String, Throwable) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$createConsumer$15(String, TokenManager, String, Map, Map, Symbol[], SenderSettleMode, ReceiverSettleMode, MonoSink) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$getSubscription$26(String, String) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$createConsumer$16(String, TokenManager, String, Map, Map, Symbol[], SenderSettleMode, ReceiverSettleMode, MonoSink) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
lambda$getCoordinator$11(String, Throwable) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
createProducer(String, String, Duration, AmqpRetryPolicy, Map) |   | 72% |   | 75% | 1 | 3 | 1 | 10 | 0 | 1 |
lambda$getSubscription$23(String) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$getCoordinator$12(String) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
removeLink(String) |  | 0% |  | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
lambda$createCoordinatorSendLink$9(Duration, AmqpRetryPolicy, MonoSink) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
lambda$createProducer$18(String, TokenManager, String, Map, Duration, AmqpRetryPolicy, String, ReactorSession.LinkSubscription) |   | 60% |   | 50% | 1 | 2 | 3 | 6 | 0 | 1 |
createConsumer(String, String, Duration, AmqpRetryPolicy) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
createConsumer(String, Receiver, ReceiveLinkHandler, TokenManager, ReactorProvider) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
createProducer(String, String, Duration, AmqpRetryPolicy) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$createConsumer$13(AmqpEndpointState) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
lambda$createCoordinatorSendLink$7(AmqpEndpointState) |  | 0% |  | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
commitTransaction(AmqpTransaction) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
rollbackTransaction(AmqpTransaction) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
createTransaction() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$rollbackTransaction$5(AmqpTransaction, TransactionCoordinator) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$commitTransaction$4(AmqpTransaction, TransactionCoordinator) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$createProducer$20(String, TokenManager, String, Map, Duration, AmqpRetryPolicy, MonoSink) |   | 78% | | n/a | 0 | 1 | 2 | 5 | 0 | 1 |
lambda$dispose$2(ErrorCondition, String, ReactorSession.LinkSubscription) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$dispose$1(ErrorCondition, String, ReactorSession.LinkSubscription) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getSubscription(String, String, Map, Duration, AmqpRetryPolicy, TokenManager) |   | 96% |   | 50% | 2 | 3 | 1 | 16 | 0 | 1 |
dispose(ErrorCondition) |   | 94% |   | 50% | 4 | 5 | 1 | 11 | 0 | 1 |
removeLink(ConcurrentMap, String) |   | 85% |   | 50% | 3 | 4 | 1 | 6 | 0 | 1 |
lambda$createTransaction$3(TransactionCoordinator) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getSubscription$24(AmqpEndpointState) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$getCoordinator$10(AmqpEndpointState) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
ReactorSession(Session, SessionHandler, String, ReactorProvider, ReactorHandlerProvider, Mono, TokenManagerProvider, MessageSerializer, Duration, AmqpRetryPolicy) |  | 100% | | n/a | 0 | 1 | 0 | 22 | 0 | 1 |
lambda$new$0(SessionHandler, String, EndpointState) |  | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
lambda$getSubscription$22(String, Throwable) |  | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
lambda$createProducer$19(String, TokenManager, String, Map, Duration, AmqpRetryPolicy, MonoSink) |  | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
lambda$createProducer$17(AmqpEndpointState) |  | 100% |  | 100% | 0 | 2 | 0 | 1 | 0 | 1 |
isDisposed() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
dispose() |  | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
session() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getEndpointStates() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getSessionName() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
getOperationTimeout() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
lambda$getSubscription$21(AmqpEndpointState) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |