ReactorSession

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total780 of 1,18934%49 of 6423%62821282113250
getSubscription(String, String, Map, Map, Symbol[], SenderSettleMode, ReceiverSettleMode, TokenManager)980%120%77212111
createConsumer(String, String, Duration, AmqpRetryPolicy, Map, Map, Symbol[], SenderSettleMode, ReceiverSettleMode)800%40%33101011
getCoordinator(String, Duration, AmqpRetryPolicy)690%n/a11121211
createCoordinatorSendLink(Duration, AmqpRetryPolicy)550%40%339911
createTransactionCoordinator()490%40%338811
lambda$createCoordinatorSendLink$8(Duration, AmqpRetryPolicy, MonoSink)450%20%227711
lambda$createTransactionCoordinator$6(AmqpSendLink)390%20%225511
lambda$createConsumer$14(String, TokenManager, String, Map, Map, Symbol[], SenderSettleMode, ReceiverSettleMode, String, ReactorSession.LinkSubscription)370%20%226611
lambda$getSubscription$25(String, String, Throwable)250%n/a113311
lambda$createConsumer$15(String, TokenManager, String, Map, Map, Symbol[], SenderSettleMode, ReceiverSettleMode, MonoSink)220%n/a113311
lambda$getSubscription$26(String, String)210%n/a113311
lambda$createConsumer$16(String, TokenManager, String, Map, Map, Symbol[], SenderSettleMode, ReceiverSettleMode, MonoSink)210%n/a115511
lambda$getCoordinator$11(String, Throwable)210%n/a113311
createProducer(String, String, Duration, AmqpRetryPolicy, Map)205372%1375%1311001
lambda$getSubscription$23(String)170%n/a113311
lambda$getCoordinator$12(String)170%n/a113311
removeLink(String)160%40%331111
lambda$createCoordinatorSendLink$9(Duration, AmqpRetryPolicy, MonoSink)150%n/a115511
lambda$createProducer$18(String, TokenManager, String, Map, Duration, AmqpRetryPolicy, String, ReactorSession.LinkSubscription)142160%1150%123601
createConsumer(String, String, Duration, AmqpRetryPolicy)140%n/a112211
createConsumer(String, Receiver, ReceiveLinkHandler, TokenManager, ReactorProvider)100%n/a112211
createProducer(String, String, Duration, AmqpRetryPolicy)80%n/a111111
lambda$createConsumer$13(AmqpEndpointState)70%20%221111
lambda$createCoordinatorSendLink$7(AmqpEndpointState)70%20%221111
commitTransaction(AmqpTransaction)60%n/a112211
rollbackTransaction(AmqpTransaction)60%n/a112211
createTransaction()50%n/a112211
lambda$rollbackTransaction$5(AmqpTransaction, TransactionCoordinator)50%n/a111111
lambda$commitTransaction$4(AmqpTransaction, TransactionCoordinator)50%n/a111111
lambda$createProducer$20(String, TokenManager, String, Map, Duration, AmqpRetryPolicy, MonoSink)41578%n/a012501
lambda$dispose$2(ErrorCondition, String, ReactorSession.LinkSubscription)40%n/a111111
lambda$dispose$1(ErrorCondition, String, ReactorSession.LinkSubscription)40%n/a111111
getSubscription(String, String, Map, Duration, AmqpRetryPolicy, TokenManager)37996%2250%2311601
dispose(ErrorCondition)35594%4450%4511101
removeLink(ConcurrentMap, String)31785%3350%341601
lambda$createTransaction$3(TransactionCoordinator)30%n/a111111
lambda$getSubscription$24(AmqpEndpointState)10%n/a111111
lambda$getCoordinator$10(AmqpEndpointState)10%n/a111111
ReactorSession(Session, SessionHandler, String, ReactorProvider, ReactorHandlerProvider, Mono, TokenManagerProvider, MessageSerializer, Duration, AmqpRetryPolicy)79100%n/a0102201
lambda$new$0(SessionHandler, String, EndpointState)22100%n/a010201
lambda$getSubscription$22(String, Throwable)21100%n/a010301
lambda$createProducer$19(String, TokenManager, String, Map, Duration, AmqpRetryPolicy, MonoSink)19100%n/a010301
lambda$createProducer$17(AmqpEndpointState)7100%2100%020101
isDisposed()4100%n/a010101
dispose()4100%n/a010201
session()3100%n/a010101
getEndpointStates()3100%n/a010101
getSessionName()3100%n/a010101
getOperationTimeout()3100%n/a010101
lambda$getSubscription$21(AmqpEndpointState)1100%n/a010101