AMQConnection

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

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,691 of 1,6910%134 of 1340%1481484484488181
start()3890%260%141410910911
AMQConnection(ConnectionParams, FrameHandler, MetricsCollector)1640%60%44424211
processControlCommand(Command)1030%180%1010313111
defaultClientProperties()810%n/a11151511
close(int, String, boolean, Throwable, int, boolean)790%120%77252511
handleConnectionClose(Command)590%20%22121211
readFrame(Frame)440%100%66171711
toString()410%20%222211
lambda$start$1()410%40%33131311
startShutdown(Method, boolean, Throwable, boolean)400%60%448811
handleSocketTimeout()370%60%447711
startMainLoop()320%n/a115511
handleHeartbeatFailure()300%n/a115511
handleFailure(Throwable)270%40%336611
createChannel(int)200%20%226611
doFinalShutdown()200%20%227711
notifyRecoveryCanBeginListeners()200%20%225511
createChannel()190%20%226611
handleReadFrame(Frame)190%20%229911
setHeartbeat(int)180%n/a116611
instantiateChannelManager(int, ThreadFactory)150%n/a113311
configureChannelManager(ChannelManager)150%n/a113311
initializeConsumerWorkService()140%n/a112211
closeMainLoopThreadIfNecessary()140%60%444411
initializeHeartbeatSender()120%n/a112211
negotiatedMaxValue(int, int)120%40%333311
shutdown(Method, boolean, Throwable, boolean)120%n/a113311
addBlockedListener(BlockedCallback, UnblockedCallback)120%n/a113311
static {...}120%n/a113311
flush()110%n/a115511
abort(int, String, int)110%n/a113311
ensureIsOpen()100%20%223311
getChannelMax()100%20%223311
disconnectChannel(ChannelN)90%20%224411
checkUnsignedShort(int)90%40%331111
finishShutdown(ShutdownSignalException)90%20%223311
close(int, String, int)90%n/a112211
close(int, String, boolean, Throwable)90%n/a112211
getHostAddress()90%20%221111
AMQConnection(ConnectionParams, FrameHandler)80%n/a112211
writeFrame(Frame)80%n/a113311
notInMainLoopThread()80%20%221111
createChannel0()70%n/a111111
mainLoopReadThreadNotNull()70%20%221111
lambda$start$2(String, ShutdownSignalException)70%n/a111111
getClientProperties()60%n/a111111
getClientProvidedName()60%n/a111111
handleIoError(Throwable)60%n/a113311
addRecoveryCanBeginListener(RecoveryCanBeginListener)60%n/a112211
removeRecoveryCanBeginListener(RecoveryCanBeginListener)60%n/a112211
close(int)60%n/a112211
close(int, String)60%n/a112211
abort(int, String)60%n/a112211
abort(int)60%n/a112211
addBlockedListener(BlockedListener)60%n/a112211
removeBlockedListener(BlockedListener)50%n/a111111
getAddress()40%n/a111111
getLocalAddress()40%n/a111111
getPort()40%n/a111111
getLocalPort()40%n/a111111
negotiateChannelMax(int, int)40%n/a111111
setThreadFactory(ThreadFactory)40%n/a112211
willShutDownConsumerExecutor()40%n/a111111
close()40%n/a112211
abort()40%n/a112211
clearBlockedListeners()40%n/a112211
setId(String)40%n/a112211
getFrameHandler()0%n/a111111
getServerProperties()0%n/a111111
getFrameMax()0%n/a111111
getHeartbeat()0%n/a111111
getThreadFactory()0%n/a111111
getExceptionHandler()0%n/a111111
isRunning()0%n/a111111
hasBrokerInitiatedShutdown()0%n/a111111
getId()0%n/a111111
getChannelRpcTimeout()0%n/a111111
willCheckRpcResponseType()0%n/a111111
getTrafficListener()0%n/a111111
checkPreconditions()0%n/a112211
lambda$new$0(Connection, IOException)0%n/a111111