ServiceBusReceiverAsyncClient

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total2,491 of 2,4910%189 of 1890%204204434434109109
updateDisposition(ServiceBusReceivedMessage, DispositionStatus, String, String, Map, ServiceBusTransactionContext)2000%200%1111333311
renewMessageLock(ServiceBusReceivedMessage, Duration)1220%140%88202011
ServiceBusReceiverAsyncClient(String, String, MessagingEntityType, ReceiverOptions, ServiceBusConnectionProcessor, Duration, TracerProvider, MessageSerializer, Runnable, ServiceBusSessionManager)1000%n/a11181811
renewSessionLock(String, Duration)980%120%77171711
ServiceBusReceiverAsyncClient(String, String, MessagingEntityType, ReceiverOptions, ServiceBusConnectionProcessor, Duration, TracerProvider, MessageSerializer, Runnable)970%n/a11181811
getOrCreateConsumer()930%40%33171711
renewMessageLock(ServiceBusReceivedMessage)760%100%66141411
receiveMessagesWithContext(int)650%100%66131311
close()650%100%66202011
setSessionState(String, byte[])550%60%44121211
getSessionState(String)550%60%44111111
renewSessionLock(String)540%60%44121211
commitTransaction(ServiceBusTransactionContext)500%60%44101011
rollbackTransaction(ServiceBusTransactionContext)500%60%44101011
lambda$peekMessages$12(String, int, ServiceBusManagementNode)480%n/a119911
deadLetter(ServiceBusReceivedMessage, DeadLetterOptions)410%60%448811
abandon(ServiceBusReceivedMessage, AbandonOptions)390%60%447711
defer(ServiceBusReceivedMessage, DeferOptions)390%60%447711
complete(ServiceBusReceivedMessage, CompleteOptions)380%60%447711
lambda$getOrCreateConsumer$45(ServiceBusReceiveLink)370%n/a114411
receiveDeferredMessage(long, String)330%20%227711
receiveDeferredMessages(Iterable, String)330%20%227711
renewMessageLock(String)330%20%227711
peekMessage(String)320%20%227711
getLinkName(String)320%100%666611
peekMessages(int, long, String)310%20%226611
lambda$getOrCreateConsumer$44(String, ServiceBusAmqpConnection)310%20%224411
peekMessage(long, String)300%20%226611
peekMessages(int, String)300%20%226611
lambda$updateDisposition$40(DispositionStatus, String, ServiceBusReceivedMessage)300%n/a115511
createTransaction()280%20%227711
lambda$updateDisposition$43(DispositionStatus, Throwable)280%50%446611
receiveDeferredMessage(long)260%20%224411
lambda$updateDisposition$42(DispositionStatus, String, ServiceBusReceivedMessage)260%n/a114411
receiveMessages()250%20%224411
lambda$peekMessage$3(String, ServiceBusManagementNode)250%n/a113311
lambda$receiveDeferredMessages$24(ServiceBusReceivedMessage)240%40%337711
lambda$receiveDeferredMessage$21(ServiceBusReceivedMessage)240%40%337711
lambda$new$1(LockRenewalOperation)240%n/a114411
lambda$new$0(LockRenewalOperation)240%n/a114411
lambda$peekMessage$5(ServiceBusReceivedMessage, SynchronousSink)210%n/a115511
lambda$peekMessages$11(ServiceBusReceivedMessage, SynchronousSink)200%n/a115511
lambda$updateDisposition$41(ServiceBusReceivedMessage, String, Mono, Boolean)170%20%226611
lambda$receiveDeferredMessage$20(String, long, ServiceBusManagementNode)140%n/a112211
lambda$peekMessages$9()140%n/a114411
lambda$updateDisposition$39(String, DispositionStatus, String, String, Map, String, ServiceBusTransactionContext, ServiceBusManagementNode)130%n/a112211
lambda$receiveMessagesNoBackPressure$15(ServiceBusMessageContext, SynchronousSink)130%20%225511
mapError(Throwable, ServiceBusErrorSource)110%20%223311
lambda$receiveDeferredMessages$23(String, Iterable, ServiceBusManagementNode)110%n/a112211
lambda$receiveMessagesWithContext$17(ServiceBusMessageContext)100%20%221111
lambda$receiveMessagesWithContext$16(ServiceBusMessageContext)100%20%221111
abandon(ServiceBusReceivedMessage)90%n/a111111
complete(ServiceBusReceivedMessage)90%n/a111111
defer(ServiceBusReceivedMessage)90%n/a111111
lambda$peekMessages$14(long, String, int, ServiceBusManagementNode)90%n/a111111
peekMessages(int, long)80%n/a111111
lambda$rollbackTransaction$37(ServiceBusTransactionContext, AmqpSession)80%n/a112211
lambda$commitTransaction$35(ServiceBusTransactionContext, AmqpSession)80%n/a112211
lambda$peekMessage$7(long, String, ServiceBusManagementNode)80%n/a111111
peekMessage(long)70%n/a111111
peekMessages(int)70%n/a111111
receiveDeferredMessages(Iterable)70%n/a111111
renewSessionLock(Duration)70%n/a111111
setSessionState(byte[])70%n/a111111
lambda$getSessionState$54(String, ServiceBusManagementNode)70%n/a111111
lambda$getSessionState$53(ServiceBusAmqpConnection)70%n/a111111
lambda$setSessionState$50(ServiceBusAmqpConnection)70%n/a111111
lambda$renewSessionLock$46(ServiceBusAmqpConnection)70%n/a111111
lambda$updateDisposition$38(ServiceBusAmqpConnection)70%n/a111111
lambda$renewMessageLock$28(String, OffsetDateTime)70%n/a111111
lambda$renewMessageLock$27(String, ServiceBusManagementNode)70%n/a111111
lambda$renewMessageLock$26(ServiceBusAmqpConnection)70%n/a111111
lambda$receiveDeferredMessages$22(ServiceBusAmqpConnection)70%n/a111111
lambda$receiveDeferredMessage$19(ServiceBusAmqpConnection)70%n/a111111
lambda$peekMessages$13(ServiceBusAmqpConnection)70%n/a111111
lambda$peekMessages$8(ServiceBusAmqpConnection)70%n/a111111
lambda$peekMessage$6(ServiceBusAmqpConnection)70%n/a111111
lambda$peekMessage$2(ServiceBusAmqpConnection)70%n/a111111
getSessionState()60%n/a111111
peekMessage()60%n/a111111
receiveMessagesNoBackPressure()60%n/a112211
renewSessionLock()60%n/a111111
lambda$setSessionState$51(String, byte[], String, ServiceBusManagementNode)60%n/a111111
lambda$createTransaction$33(AmqpTransaction)60%n/a111111
deadLetter(ServiceBusReceivedMessage)50%n/a111111
isManagementToken(String)50%n/a111111
lambda$getSessionState$55(Throwable)50%n/a111111
lambda$setSessionState$52(Throwable)50%n/a111111
lambda$renewSessionLock$49(Throwable)50%n/a111111
lambda$renewSessionLock$48(Throwable)50%n/a111111
lambda$renewSessionLock$47(String, String, ServiceBusManagementNode)50%n/a111111
lambda$renewMessageLock$30(Throwable)50%n/a111111
lambda$renewMessageLock$25(Throwable)50%n/a111111
lambda$receiveMessagesWithContext$18(Throwable)50%n/a111111
lambda$peekMessages$10(ServiceBusReceivedMessage, long)50%n/a111111
lambda$peekMessage$4(ServiceBusReceivedMessage, long)50%n/a111111
static {...}50%n/a111111
receiveMessagesWithContext()40%n/a111111
isConnectionClosed()40%n/a111111
isManagementNodeLocksClosed()40%n/a111111
isRenewalContainerClosed()40%n/a111111
lambda$rollbackTransaction$36(ServiceBusAmqpConnection)40%n/a111111
lambda$commitTransaction$34(ServiceBusAmqpConnection)40%n/a111111
lambda$createTransaction$31(ServiceBusAmqpConnection)40%n/a111111
lambda$renewMessageLock$29(ServiceBusReceivedMessage, String)40%n/a111111
getFullyQualifiedNamespace()30%n/a111111
getEntityPath()30%n/a111111
getReceiverOptions()30%n/a111111
lambda$createTransaction$32(AmqpSession)30%n/a111111