PublisherCallbackChannelImpl

Source file "org/springframework/amqp/rabbit/connection/PublisherCallbackChannelImpl.java" was not found during generation of report.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,604 of 1,6040%112 of 1120%186186349349130130
processMultipleAck(long, boolean)1110%120%77242411
doProcessAck(long, boolean, boolean, boolean)940%160%99212111
generateNacksForPendingAcks(String)850%80%55161611
lambda$doHandleConfirm$1(PublisherCallbackChannel.Listener, PendingConfirm, boolean)720%140%88212111
findConfirm(Return)610%60%44141411
handle(Return)570%100%66131311
expire(PublisherCallbackChannel.Listener, long)560%100%66151511
addPendingConfirm(PublisherCallbackChannel.Listener, long, PendingConfirm)520%40%33101011
addListener(PublisherCallbackChannel.Listener)470%60%449911
close()410%40%339911
PublisherCallbackChannelImpl(Channel, ExecutorService)400%n/a11111111
handleAck(long, boolean)290%20%224411
handleNack(long, boolean)290%20%224411
findListener(AMQP.BasicProperties)290%40%339911
close(int, String)140%20%224411
getPendingConfirmsCount(PublisherCallbackChannel.Listener)140%20%224411
processAck(long, boolean, boolean, boolean)140%n/a115511
lambda$handle$2(PublisherCallbackChannel.Listener, Return, PendingConfirm)140%20%226611
setAfterAckCallback(Consumer)130%40%334411
basicConsume(String, boolean, String, boolean, boolean, Map, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback)130%n/a111111
basicConsume(String, boolean, String, boolean, boolean, Map, DeliverCallback, CancelCallback)120%n/a111111
basicConsume(String, boolean, String, boolean, boolean, Map, DeliverCallback, ConsumerShutdownSignalCallback)120%n/a111111
equals(Object)120%40%331111
basicConsume(String, boolean, String, boolean, boolean, Map, Consumer)110%n/a111111
toString()110%n/a111111
exchangeDeclare(String, String, boolean, boolean, boolean, Map)100%n/a111111
exchangeDeclare(String, BuiltinExchangeType, boolean, boolean, boolean, Map)100%n/a111111
basicConsume(String, boolean, String, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback)100%n/a111111
basicConsume(String, boolean, Map, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback)100%n/a111111
exchangeDeclareNoWait(String, String, boolean, boolean, boolean, Map)100%n/a112211
exchangeDeclareNoWait(String, BuiltinExchangeType, boolean, boolean, boolean, Map)100%n/a112211
basicPublish(String, String, boolean, boolean, AMQP.BasicProperties, byte[])90%n/a112211
basicPublish(String, String, boolean, AMQP.BasicProperties, byte[])90%n/a112211
exchangeDeclare(String, String, boolean, boolean, Map)90%n/a111111
exchangeDeclare(String, BuiltinExchangeType, boolean, boolean, Map)90%n/a111111
queueDeclare(String, boolean, boolean, boolean, Map)90%n/a111111
basicConsume(String, boolean, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback)90%n/a111111
basicConsume(String, boolean, String, DeliverCallback, CancelCallback)90%n/a111111
basicConsume(String, boolean, String, DeliverCallback, ConsumerShutdownSignalCallback)90%n/a111111
basicConsume(String, boolean, Map, DeliverCallback, CancelCallback)90%n/a111111
basicConsume(String, boolean, Map, DeliverCallback, ConsumerShutdownSignalCallback)90%n/a111111
exchangeBindNoWait(String, String, String, Map)90%n/a112211
queueDeclareNoWait(String, boolean, boolean, boolean, Map)90%n/a112211
doHandleConfirm(boolean, PublisherCallbackChannel.Listener, PendingConfirm)90%n/a112211
basicPublish(String, String, AMQP.BasicProperties, byte[])80%n/a112211
exchangeBind(String, String, String, Map)80%n/a112211
exchangeUnbind(String, String, String, Map)80%n/a111111
queueBind(String, String, String, Map)80%n/a111111
queueUnbind(String, String, String, Map)80%n/a111111
basicConsume(String, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback)80%n/a111111
basicConsume(String, boolean, DeliverCallback, CancelCallback)80%n/a111111
basicConsume(String, boolean, DeliverCallback, ConsumerShutdownSignalCallback)80%n/a111111
basicConsume(String, boolean, String, Consumer)80%n/a111111
basicConsume(String, boolean, Map, Consumer)80%n/a111111
exchangeUnbindNoWait(String, String, String, Map)80%n/a112211
queueBindNoWait(String, String, String, Map)80%n/a112211
getPendingConfirmsCount()80%n/a113311
basicQos(int, int, boolean)70%n/a112211
exchangeDeclare(String, String, boolean)70%n/a111111
exchangeDeclare(String, BuiltinExchangeType, boolean)70%n/a111111
exchangeBind(String, String, String)70%n/a111111
exchangeUnbind(String, String, String)70%n/a111111
queueDelete(String, boolean, boolean)70%n/a111111
queueBind(String, String, String)70%n/a111111
queueUnbind(String, String, String)70%n/a111111
basicNack(long, boolean, boolean)70%n/a112211
basicConsume(String, DeliverCallback, CancelCallback)70%n/a111111
basicConsume(String, DeliverCallback, ConsumerShutdownSignalCallback)70%n/a111111
basicConsume(String, boolean, Consumer)70%n/a111111
queueDeleteNoWait(String, boolean, boolean)70%n/a112211
shutdownCompleted(String)70%n/a112211
abort(int, String)60%n/a112211
basicQos(int, boolean)60%n/a112211
exchangeDeclare(String, String)60%n/a111111
exchangeDeclare(String, BuiltinExchangeType)60%n/a111111
exchangeDelete(String, boolean)60%n/a111111
basicGet(String, boolean)60%n/a111111
basicAck(long, boolean)60%n/a112211
basicReject(long, boolean)60%n/a112211
basicConsume(String, Consumer)60%n/a111111
addConfirmListener(ConfirmCallback, ConfirmCallback)60%n/a111111
exchangeDeleteNoWait(String, boolean)60%n/a112211
lambda$factory$3(Channel, ExecutorService)60%n/a111111
addShutdownListener(ShutdownListener)50%n/a112211
removeShutdownListener(ShutdownListener)50%n/a112211
setDefaultConsumer(Consumer)50%n/a112211
basicQos(int)50%n/a112211
exchangeDeclarePassive(String)50%n/a111111
exchangeDelete(String)50%n/a111111
queueDeclarePassive(String)50%n/a111111
queueDelete(String)50%n/a111111
queuePurge(String)50%n/a111111
basicCancel(String)50%n/a112211
basicRecover(boolean)50%n/a111111
waitForConfirms(long)50%n/a111111
waitForConfirmsOrDie(long)50%n/a112211
asyncRpc(Method)50%n/a112211
rpc(Method)50%n/a111111
addConfirmListener(ConfirmListener)50%n/a112211
removeConfirmListener(ConfirmListener)50%n/a111111
addReturnListener(ReturnListener)50%n/a112211
addReturnListener(ReturnCallback)50%n/a111111
removeReturnListener(ReturnListener)50%n/a111111
consumerCount(String)50%n/a111111
asyncCompletableRpc(Method)50%n/a111111
messageCount(String)50%n/a111111
shutdownCompleted(ShutdownSignalException)50%n/a112211
static {...}50%n/a111111
getCloseReason()40%n/a111111
notifyListeners()40%n/a112211
isOpen()40%n/a111111
getChannelNumber()40%n/a111111
getConnection()40%n/a111111
abort()40%n/a112211
getDefaultConsumer()40%n/a111111
queueDeclare()40%n/a111111
basicRecover()40%n/a111111
txSelect()40%n/a111111
txCommit()40%n/a111111
txRollback()40%n/a111111
confirmSelect()40%n/a111111
getNextPublishSeqNo()40%n/a111111
waitForConfirms()40%n/a111111
waitForConfirmsOrDie()40%n/a112211
clearConfirmListeners()40%n/a112211
clearReturnListeners()40%n/a112211
hashCode()40%n/a111111
lambda$shutdownCompleted$0(String)40%n/a111111
getDelegate()30%n/a111111
factory()20%n/a111111