AutorecoveringChannel

Source file "com/rabbitmq/client/impl/recovery/AutorecoveringChannel.java" was not found during generation of report.

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,618 of 1,6180%54 of 540%168168375375141141
recordOnRpcResponse(Method, Method)1240%160%99373711
recordOnRpcRequest(Method)620%80%55171711
automaticallyRecover(AutorecoveringConnection, Connection)480%20%22141411
AutorecoveringChannel(AutorecoveringConnection, RecoveryAwareChannelN)350%n/a119911
recordQueue(AMQP.Queue.DeclareOk, String, boolean, boolean, boolean, Map)320%20%22101011
queueDeclareNoWait(String, boolean, boolean, boolean, Map)310%n/a119911
recoverState()290%80%559911
exchangeDeclareNoWait(String, String, boolean, boolean, boolean, Map)280%n/a118811
recordConsumer(String, String, boolean, boolean, Map, Consumer)270%n/a119911
executeAndClean(Utils.IoTimeoutExceptionRunnable)230%20%226611
basicConsume(String, boolean, String, boolean, boolean, Map, Consumer)210%n/a113311
exchangeDeclare(String, String, boolean, boolean, boolean, Map)200%n/a113311
queueDeclare(String, boolean, boolean, boolean, Map)190%n/a113311
recordExchange(AMQP.Exchange.DeclareOk, String, String, boolean, boolean, Map)190%n/a117711
updateConsumerTag(String, String)190%n/a115511
exchangeUnbind(String, String, String, Map)180%n/a113311
queueUnbind(String, String, String, Map)180%n/a113311
deleteRecordedConsumer(String)180%20%225511
recoverShutdownListeners()170%20%224411
recoverReturnListeners()170%20%224411
recoverConfirmListeners()170%20%224411
basicQos(int, int, boolean)160%20%225511
exchangeBind(String, String, String, Map)160%n/a113311
queueBind(String, String, String, Map)160%n/a113311
notifyRecoveryListenersComplete()160%20%224411
notifyRecoveryListenersStarted()160%20%224411
asyncCompletableRpc(Method)160%n/a114411
exchangeUnbindNoWait(String, String, String, Map)150%n/a113311
rpc(Method)150%n/a114411
exchangeBindNoWait(String, String, String, Map)140%n/a113311
queueBindNoWait(String, String, String, Map)140%n/a113311
basicConsume(String, boolean, String, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback)140%n/a111111
basicConsume(String, boolean, Map, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback)140%n/a111111
basicConsume(String, boolean, String, boolean, boolean, Map, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback)140%n/a111111
basicConsume(String, boolean, String, DeliverCallback, CancelCallback)130%n/a111111
basicConsume(String, boolean, String, DeliverCallback, ConsumerShutdownSignalCallback)130%n/a111111
basicConsume(String, boolean, Map, DeliverCallback, CancelCallback)130%n/a111111
basicConsume(String, boolean, Map, DeliverCallback, ConsumerShutdownSignalCallback)130%n/a111111
basicConsume(String, boolean, String, boolean, boolean, Map, DeliverCallback, CancelCallback)130%n/a111111
basicConsume(String, boolean, String, boolean, boolean, Map, DeliverCallback, ConsumerShutdownSignalCallback)130%n/a111111
addConfirmListener(ConfirmCallback, ConfirmCallback)120%n/a113311
lambda$addReturnListener$4(ReturnCallback, int, String, String, String, AMQP.BasicProperties, byte[])120%n/a111111
basicConsume(String, boolean, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback)110%n/a111111
addReturnListener(ReturnListener)100%n/a113311
removeReturnListener(ReturnListener)100%n/a112211
addConfirmListener(ConfirmListener)100%n/a113311
removeConfirmListener(ConfirmListener)100%n/a112211
basicPublish(String, String, boolean, boolean, AMQP.BasicProperties, byte[])100%n/a112211
exchangeDeclare(String, BuiltinExchangeType, boolean, boolean, boolean, Map)100%n/a111111
exchangeDeclareNoWait(String, BuiltinExchangeType, boolean, boolean, boolean, Map)100%n/a112211
queueDelete(String, boolean, boolean)100%n/a112211
queueDeleteNoWait(String, boolean, boolean)100%n/a113311
basicConsume(String, DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback)100%n/a111111
basicConsume(String, boolean, DeliverCallback, CancelCallback)100%n/a111111
basicConsume(String, boolean, DeliverCallback, ConsumerShutdownSignalCallback)100%n/a111111
basicConsume(String, boolean, String, Consumer)100%n/a111111
basicConsume(String, boolean, Map, Consumer)100%n/a111111
addShutdownListener(ShutdownListener)100%n/a113311
removeShutdownListener(ShutdownListener)100%n/a113311
abort(int, String)90%n/a114411
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
exchangeDelete(String, boolean)90%n/a112211
exchangeDeleteNoWait(String, boolean)90%n/a113311
recordQueueBinding(String, String, String, Map)90%n/a112211
deleteRecordedQueueBinding(String, String, String, Map)90%n/a111111
recordExchangeBinding(String, String, String, Map)90%n/a112211
deleteRecordedExchangeBinding(String, String, String, Map)90%n/a111111
addReturnListener(ReturnCallback)80%n/a113311
basicPublish(String, String, AMQP.BasicProperties, byte[])80%n/a112211
exchangeDeclare(String, String)80%n/a111111
exchangeDeclare(String, String, boolean)80%n/a111111
queueDeclare()80%n/a111111
basicConsume(String, DeliverCallback, CancelCallback)80%n/a111111
basicConsume(String, DeliverCallback, ConsumerShutdownSignalCallback)80%n/a111111
consumerFromDeliverCancelShutdownCallbacks(DeliverCallback, CancelCallback, ConsumerShutdownSignalCallback)80%n/a111111
basicCancel(String)80%n/a113311
lambda$asyncCompletableRpc$5(Method, Command)80%20%223311
close(int, String)70%n/a112211
abort()70%n/a114411
clearReturnListeners()70%n/a113311
clearConfirmListeners()70%n/a113311
exchangeDeclare(String, BuiltinExchangeType, boolean)70%n/a111111
exchangeBind(String, String, String)70%n/a111111
exchangeUnbind(String, String, String)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, boolean, Consumer)70%n/a111111
consumerFromDeliverCancelCallbacks(DeliverCallback, CancelCallback)70%n/a111111
consumerFromDeliverShutdownCallbacks(DeliverCallback, ConsumerShutdownSignalCallback)70%n/a111111
txSelect()70%n/a112211
confirmSelect()70%n/a112211
basicQos(int)60%n/a112211
basicQos(int, boolean)60%n/a112211
exchangeDeclare(String, BuiltinExchangeType)60%n/a111111
queueDelete(String)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
addRecoveryListener(RecoveryListener)60%n/a112211
removeRecoveryListener(RecoveryListener)60%n/a112211
recordQueue(AMQP.Queue.DeclareOk, RecordedQueue)60%n/a112211
recordQueue(String, RecordedQueue)60%n/a112211
recordExchange(String, RecordedExchange)60%n/a112211
lambda$abort$3(int, String)60%n/a111111
lambda$close$1(int, String)60%n/a111111
close()50%n/a112211
setDefaultConsumer(Consumer)50%n/a112211
exchangeDeclarePassive(String)50%n/a111111
exchangeDelete(String)50%n/a111111
queueDeclarePassive(String)50%n/a111111
messageCount(String)50%n/a111111
consumerCount(String)50%n/a111111
queuePurge(String)50%n/a111111
basicRecover(boolean)50%n/a111111
waitForConfirms(long)50%n/a111111
waitForConfirmsOrDie(long)50%n/a112211
asyncRpc(Method)50%n/a112211
deleteRecordedQueue(String)50%n/a112211
deleteRecordedExchange(String)50%n/a112211
maybeDeleteRecordedAutoDeleteExchange(String)50%n/a112211
getChannelNumber()40%n/a111111
getConnection()40%n/a111111
getDefaultConsumer()40%n/a111111
basicRecover()40%n/a111111
txCommit()40%n/a111111
txRollback()40%n/a111111
getNextPublishSeqNo()40%n/a111111
waitForConfirms()40%n/a111111
waitForConfirmsOrDie()40%n/a112211
getCloseReason()40%n/a111111
notifyListeners()40%n/a112211
isOpen()40%n/a111111
toString()40%n/a111111
lambda$abort$2()40%n/a111111
lambda$close$0()40%n/a111111
static {...}40%n/a111111
getDelegate()30%n/a111111