Source file "com/rabbitmq/client/impl/recovery/AutorecoveringConnection.java" was not found during generation of report.
| Element | Missed Instructions | Cov. | Missed Branches | Cov. | Missed | Cxty | Missed | Lines | Missed | Methods |
| Total | 2,108 of 2,108 | 0% | 156 of 156 | 0% | 193 | 193 | 536 | 536 | 115 | 115 |
| recoverTopology(ExecutorService) | | 0% | | 0% | 6 | 6 | 23 | 23 | 1 | 1 |
| AutorecoveringConnection(ConnectionParams, FrameHandlerFactory, AddressResolver, MetricsCollector) | | 0% | | 0% | 4 | 4 | 24 | 24 | 1 | 1 |
| internalRecoverConsumer(String, RecordedConsumer, boolean) | | 0% | | 0% | 6 | 6 | 21 | 21 | 1 | 1 |
| wrapRetryIfNecessary(RecordedEntity, Callable) | | 0% | | 0% | 6 | 6 | 17 | 17 | 1 | 1 |
| internalRecoverQueue(String, RecordedQueue, boolean) | | 0% | | 0% | 5 | 5 | 21 | 21 | 1 | 1 |
| recoverChannelAndTopology(AutorecoveringChannel) | | 0% | | 0% | 2 | 2 | 22 | 22 | 1 | 1 |
| recoverBinding(RecordedBinding, boolean) | | 0% | | 0% | 3 | 3 | 15 | 15 | 1 | 1 |
| recoverExchange(RecordedExchange, boolean) | | 0% | | 0% | 3 | 3 | 15 | 15 | 1 | 1 |
| lambda$groupEntitiesByChannel$16(List) | | 0% | | 0% | 6 | 6 | 13 | 13 | 1 | 1 |
| beginAutomaticRecovery() | | 0% | | 0% | 4 | 4 | 18 | 18 | 1 | 1 |
| groupEntitiesByChannel(Collection) | | 0% | | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
| recoverConnection() | | 0% | | 0% | 3 | 3 | 15 | 15 | 1 | 1 |
| maybeDeleteRecordedAutoDeleteQueue(String) | | 0% | | 0% | 4 | 4 | 9 | 9 | 1 | 1 |
| recoverQueue(String, RecordedQueue, boolean) | | 0% | n/a | 1 | 1 | 8 | 8 | 1 | 1 | |
| recoverConsumer(String, RecordedConsumer, boolean) | | 0% | n/a | 1 | 1 | 8 | 8 | 1 | 1 | |
| recoverEntitiesAsynchronously(ExecutorService, Collection) | | 0% | | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
| removeBindingsWithDestination(String) | | 0% | | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
| excludeQueueFromRecovery(String, boolean) | | 0% | | 0% | 3 | 3 | 9 | 9 | 1 | 1 |
| maybeDeleteRecordedAutoDeleteExchange(String) | | 0% | | 0% | 4 | 4 | 7 | 7 | 1 | 1 |
| recoverChannels(RecoveryAwareAMQConnection) | | 0% | | 0% | 2 | 2 | 8 | 8 | 1 | 1 |
| deleteRecordedQueue(String) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| deleteRecordedExchange(String) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| recordQueueBinding(AutorecoveringChannel, String, String, String, Map) | | 0% | n/a | 1 | 1 | 8 | 8 | 1 | 1 | |
| recordExchangeBinding(AutorecoveringChannel, String, String, String, Map) | | 0% | n/a | 1 | 1 | 8 | 8 | 1 | 1 | |
| propagateQueueNameChangeToConsumers(String, String) | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
| hasMoreDestinationsBoundToExchange(List, String) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| hasMoreConsumersOnQueue(Collection, String) | | 0% | | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
| propagateQueueNameChangeToBindings(String, String) | | 0% | | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
| close(int, String, int) | | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | |
| abort(int, String, int) | | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | |
| addAutomaticRecoveryListener(RecoveryAwareAMQConnection) | | 0% | n/a | 1 | 1 | 6 | 6 | 1 | 1 | |
| deleteRecordedQueueBinding(AutorecoveringChannel, String, String, String, Map) | | 0% | n/a | 1 | 1 | 6 | 6 | 1 | 1 | |
| deleteRecordedExchangeBinding(AutorecoveringChannel, String, String, String, Map) | | 0% | n/a | 1 | 1 | 6 | 6 | 1 | 1 | |
| lambda$setupErrorOnWriteListenerForPotentialRecovery$2(Lock, ThreadFactory, Connection, IOException) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| abort(int, String) | | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | |
| close(int, String) | | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | |
| recoverShutdownListeners(RecoveryAwareAMQConnection) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| recoverBlockedListeners(RecoveryAwareAMQConnection) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| notifyRecoveryListenersComplete() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| notifyRecoveryListenersStarted() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| notifyTopologyRecoveryListenersStarted() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| close(int) | | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | |
| abort(int) | | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | |
| setupErrorOnWriteListenerForPotentialRecovery() | | 0% | n/a | 1 | 1 | 4 | 4 | 1 | 1 | |
| wrapChannel(RecoveryAwareChannelN) | | 0% | | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
| close() | | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | |
| abort() | | 0% | n/a | 1 | 1 | 5 | 5 | 1 | 1 | |
| createChannel(int) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| lambda$addAutomaticRecoveryListener$3(AutorecoveringConnection, RecoveryAwareAMQConnection, ShutdownSignalException) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
| createChannel() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| addBlockedListener(BlockedCallback, UnblockedCallback) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| lambda$static$0(ShutdownSignalException) | | 0% | | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
| init() | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| addBlockedListener(BlockedListener) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| removeBlockedListener(BlockedListener) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| addShutdownListener(ShutdownListener) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| removeShutdownListener(ShutdownListener) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| AutorecoveringConnection(ConnectionParams, FrameHandlerFactory, List) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| AutorecoveringConnection(ConnectionParams, FrameHandlerFactory, AddressResolver) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| registerChannel(AutorecoveringChannel) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| unregisterChannel(AutorecoveringChannel) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| recordQueue(AMQP.Queue.DeclareOk, RecordedQueue) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| lambda$recoverChannelAndTopology$10(AutorecoveringChannel, RecordedConsumer) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$recoverChannelAndTopology$8(AutorecoveringChannel, RecordedBinding) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$recoverChannelAndTopology$6(AutorecoveringChannel, RecordedQueue) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| lambda$recoverChannelAndTopology$4(AutorecoveringChannel, RecordedExchange) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
| clearBlockedListeners() | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| recordQueue(String, RecordedQueue) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| recordExchange(String, RecordedExchange) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| recordConsumer(String, RecordedConsumer) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| lambda$recoverChannelAndTopology$11(RecordedConsumer) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$recoverChannelAndTopology$7(RecordedQueue) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$null$1(Connection, IOException) | | 0% | n/a | 1 | 1 | 3 | 3 | 1 | 1 | |
| addRecoveryListener(RecoveryListener) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| removeRecoveryListener(RecoveryListener) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| addQueueRecoveryListener(QueueRecoveryListener) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| removeQueueRecoveryListener(QueueRecoveryListener) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| addConsumerRecoveryListener(ConsumerRecoveryListener) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| removeConsumerRecoveryListener(ConsumerRecoveryListener) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| recoverChannel(AutorecoveringChannel) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| recoverQueue(String, RecordedQueue) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| recoverConsumer(String, RecordedConsumer) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| deleteRecordedConsumer(String) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| static {...} | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| shouldTriggerConnectionRecovery(ShutdownSignalException) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| setId(String) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| lambda$recoverChannelAndTopology$9(RecordedBinding) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$recoverChannelAndTopology$5(RecordedExchange) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| letAllPassFilter() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getServerProperties() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getClientProperties() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getClientProvidedName() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getFrameMax() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getHeartbeat() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getChannelMax() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| isOpen() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getCloseReason() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| notifyListeners() | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| getExceptionHandler() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getPort() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getAddress() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getLocalAddress() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getLocalPort() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| toString() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getId() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$groupEntitiesByChannel$15(AutorecoveringChannel) | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| lambda$recoverBinding$14(RecordedBinding) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| lambda$internalRecoverQueue$13(RecordedQueue) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| lambda$recoverExchange$12(RecordedExchange) | | 0% | n/a | 1 | 1 | 2 | 2 | 1 | 1 | |
| getDelegate() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getRecoveredQueueNameSupplier() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getRecordedQueues() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getRecordedExchanges() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getRecordedBindings() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 | |
| getRecordedConsumers() | | 0% | n/a | 1 | 1 | 1 | 1 | 1 | 1 |