ServiceBusReceiverAsyncClient

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total782 of 2,46968%80 of 18556%9120212443222109
renewMessageLock(ServiceBusReceivedMessage, Duration)556754%5964%5872001
commitTransaction(ServiceBusTransactionContext)500%60%44101011
rollbackTransaction(ServiceBusTransactionContext)500%60%44101011
updateDisposition(ServiceBusReceivedMessage, DispositionStatus, String, String, Map, ServiceBusTransactionContext)4315778%51575%51153301
renewSessionLock(String, Duration)395960%4866%4751701
renewMessageLock(ServiceBusReceivedMessage)393748%4660%4651401
createTransaction()280%20%227711
lambda$new$1(LockRenewalOperation)240%n/a114411
getSessionState(String)213461%2466%2431101
setSessionState(String, byte[])203563%2466%2431201
renewSessionLock(String)203462%2466%2431201
abandon(ServiceBusReceivedMessage, AbandonOptions)192051%3350%343701
defer(ServiceBusReceivedMessage, DeferOptions)192051%3350%343701
complete(ServiceBusReceivedMessage, CompleteOptions)182052%3350%343701
lambda$receiveDeferredMessage$21(ServiceBusReceivedMessage)18625%3125%235701
lambda$updateDisposition$41(ServiceBusReceivedMessage, String, Mono, Boolean)170%20%226611
close()154173%2675%2541801
receiveDeferredMessage(long, String)151854%1150%122701
receiveDeferredMessages(Iterable, String)151854%1150%122701
renewMessageLock(String)151854%1150%122701
peekMessage(String)151753%1150%122701
peekMessages(int, long, String)151651%1150%122601
peekMessage(long, String)151550%1150%122601
peekMessages(int, String)151550%1150%122601
receiveDeferredMessage(long)151142%1150%122401
receiveMessages()151040%1150%122401
receiveMessagesWithContext(int)134979%1787%1511301
getLinkName(String)131959%5550%462601
lambda$receiveMessagesWithContext$17(ServiceBusMessageContext)100%20%221111
getOrCreateConsumer()97489%2250%2331701
deadLetter(ServiceBusReceivedMessage, DeadLetterOptions)83380%2466%241801
lambda$updateDisposition$43(DispositionStatus, Throwable)82071%2360%242601
lambda$rollbackTransaction$37(ServiceBusTransactionContext, AmqpSession)80%n/a112211
lambda$commitTransaction$35(ServiceBusTransactionContext, AmqpSession)80%n/a112211
renewSessionLock(Duration)70%n/a111111
setSessionState(byte[])70%n/a111111
getSessionState()60%n/a111111
renewSessionLock()60%n/a111111
lambda$createTransaction$33(AmqpTransaction)60%n/a111111
lambda$receiveMessagesNoBackPressure$15(ServiceBusMessageContext, SynchronousSink)5861%1150%122501
lambda$getSessionState$55(Throwable)50%n/a111111
lambda$setSessionState$52(Throwable)50%n/a111111
lambda$renewSessionLock$49(Throwable)50%n/a111111
isConnectionClosed()40%n/a111111
lambda$rollbackTransaction$36(ServiceBusAmqpConnection)40%n/a111111
lambda$commitTransaction$34(ServiceBusAmqpConnection)40%n/a111111
lambda$createTransaction$31(ServiceBusAmqpConnection)40%n/a111111
getReceiverOptions()30%n/a111111
lambda$createTransaction$32(AmqpSession)30%n/a111111
lambda$receiveMessagesWithContext$16(ServiceBusMessageContext)990%1150%120101
ServiceBusReceiverAsyncClient(String, String, MessagingEntityType, ReceiverOptions, ServiceBusConnectionProcessor, Duration, TracerProvider, MessageSerializer, Runnable, ServiceBusSessionManager)100100%n/a0101801
ServiceBusReceiverAsyncClient(String, String, MessagingEntityType, ReceiverOptions, ServiceBusConnectionProcessor, Duration, TracerProvider, MessageSerializer, Runnable)97100%n/a0101801
lambda$peekMessages$12(String, int, ServiceBusManagementNode)48100%n/a010901
lambda$getOrCreateConsumer$45(ServiceBusReceiveLink)37100%n/a010401
lambda$getOrCreateConsumer$44(String, ServiceBusAmqpConnection)31100%2100%020401
lambda$updateDisposition$40(DispositionStatus, String, ServiceBusReceivedMessage)30100%n/a010501
lambda$updateDisposition$42(DispositionStatus, String, ServiceBusReceivedMessage)26100%n/a010401
lambda$peekMessage$3(String, ServiceBusManagementNode)25100%n/a010301
lambda$receiveDeferredMessages$24(ServiceBusReceivedMessage)24100%1375%130701
lambda$new$0(LockRenewalOperation)24100%n/a010401
lambda$peekMessage$5(ServiceBusReceivedMessage, SynchronousSink)21100%n/a010501
lambda$peekMessages$11(ServiceBusReceivedMessage, SynchronousSink)20100%n/a010501
lambda$receiveDeferredMessage$20(String, long, ServiceBusManagementNode)14100%n/a010201
lambda$peekMessages$9()14100%n/a010401
lambda$updateDisposition$39(String, DispositionStatus, String, String, Map, String, ServiceBusTransactionContext, ServiceBusManagementNode)13100%n/a010201
mapError(Throwable, ServiceBusErrorSource)11100%2100%020301
lambda$receiveDeferredMessages$23(String, Iterable, ServiceBusManagementNode)11100%n/a010201
abandon(ServiceBusReceivedMessage)9100%n/a010101
complete(ServiceBusReceivedMessage)9100%n/a010101
defer(ServiceBusReceivedMessage)9100%n/a010101
lambda$peekMessages$14(long, String, int, ServiceBusManagementNode)9100%n/a010101
peekMessages(int, long)8100%n/a010101
lambda$peekMessage$7(long, String, ServiceBusManagementNode)8100%n/a010101
peekMessage(long)7100%n/a010101
peekMessages(int)7100%n/a010101
receiveDeferredMessages(Iterable)7100%n/a010101
lambda$getSessionState$54(String, ServiceBusManagementNode)7100%n/a010101
lambda$getSessionState$53(ServiceBusAmqpConnection)7100%n/a010101
lambda$setSessionState$50(ServiceBusAmqpConnection)7100%n/a010101
lambda$renewSessionLock$46(ServiceBusAmqpConnection)7100%n/a010101
lambda$updateDisposition$38(ServiceBusAmqpConnection)7100%n/a010101
lambda$renewMessageLock$28(String, OffsetDateTime)7100%n/a010101
lambda$renewMessageLock$27(String, ServiceBusManagementNode)7100%n/a010101
lambda$renewMessageLock$26(ServiceBusAmqpConnection)7100%n/a010101
lambda$receiveDeferredMessages$22(ServiceBusAmqpConnection)7100%n/a010101
lambda$receiveDeferredMessage$19(ServiceBusAmqpConnection)7100%n/a010101
lambda$peekMessages$13(ServiceBusAmqpConnection)7100%n/a010101
lambda$peekMessages$8(ServiceBusAmqpConnection)7100%n/a010101
lambda$peekMessage$6(ServiceBusAmqpConnection)7100%n/a010101
lambda$peekMessage$2(ServiceBusAmqpConnection)7100%n/a010101
peekMessage()6100%n/a010101
receiveMessagesNoBackPressure()6100%n/a010201
lambda$setSessionState$51(String, byte[], String, ServiceBusManagementNode)6100%n/a010101
deadLetter(ServiceBusReceivedMessage)5100%n/a010101
isManagementToken(String)5100%n/a010101
lambda$renewSessionLock$48(Throwable)5100%n/a010101
lambda$renewSessionLock$47(String, String, ServiceBusManagementNode)5100%n/a010101
lambda$renewMessageLock$30(Throwable)5100%n/a010101
lambda$renewMessageLock$25(Throwable)5100%n/a010101
lambda$receiveMessagesWithContext$18(Throwable)5100%n/a010101
lambda$peekMessages$10(ServiceBusReceivedMessage, long)5100%n/a010101
lambda$peekMessage$4(ServiceBusReceivedMessage, long)5100%n/a010101
static {...}5100%n/a010101
receiveMessagesWithContext()4100%n/a010101
isManagementNodeLocksClosed()4100%n/a010101
isRenewalContainerClosed()4100%n/a010101
lambda$renewMessageLock$29(ServiceBusReceivedMessage, String)4100%n/a010101
getFullyQualifiedNamespace()3100%n/a010101
getEntityPath()3100%n/a010101