RabbitTemplate

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

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total3,899 of 3,8990%438 of 4380%422422899899203203
doSend(Channel, String, String, Message, boolean, CorrelationData)1230%180%1010232311
doSendAndReceiveAsListener(String, String, Message, CorrelationData, Channel, boolean)1140%180%1010242411
invoke(RabbitOperations.OperationsCallback, ConfirmCallback, ConfirmCallback)1090%160%99303011
RabbitTemplate(ConnectionFactory)1000%n/a11252511
RabbitTemplate()990%n/a11252511
doExecute(ChannelCallback, ConnectionFactory)990%140%88323211
lambda$doSendAndReceiveWithTemporary$10(Message, String, String, CorrelationData, Channel)970%40%33242411
consumeDelivery(Channel, String, long)930%100%66272711
receiveForReply(String, Channel)870%160%99222211
setupConfirm(Channel, Message, CorrelationData)860%220%1212222211
onMessage(Message, Channel)850%160%99181811
handleReturn(Return)840%120%77212111
saveAndSetProperties(Message, RabbitTemplate.PendingReply, String)780%120%77191911
doSendAndReceiveWithDirect(String, String, Message, CorrelationData)770%140%88202011
sendReply(ReceiveAndReplyCallback, ReplyToAddressCallback, Channel, Message)740%100%66151511
doSendReply(ReplyToAddressCallback, Channel, Message, Object)720%140%88191911
createReplyToContainer(ConnectionFactory)700%60%44161611
createConsumer(String, Channel, CompletableFuture, long)600%40%33101011
shouldRethrow(AmqpException)580%120%77121211
restoreProperties(Message, RabbitTemplate.PendingReply)550%100%66121211
obtainTargetConnectionFactory(Expression, Object)540%120%77131311
expectedQueueNames()520%80%55101011
exchangeMessages(String, String, Message, CorrelationData, Channel, RabbitTemplate.PendingReply, String)520%80%559911
addListener(Channel)520%80%55111111
getUnconfirmed(long)500%60%449911
doSendAndReceive(String, String, Message, CorrelationData)480%120%77101011
lambda$receive$5(String, long, Channel)460%60%44111111
lambda$doReceiveNoWait$4(String, Channel)430%80%55101011
buildMessage(Envelope, AMQP.BasicProperties, byte[], int)410%60%449911
useDirectReplyTo()360%100%66101011
invokeAction(ChannelCallback, ConnectionFactory, Channel)320%40%336611
setReturnCallback(RabbitTemplate.ReturnCallback)310%80%554411
logReceived(String, Message)300%40%335511
waitForConfirmsOrDie(long)270%20%22101011
revoke(Channel)270%20%225511
waitForConfirms(long)260%20%228811
lambda$send$3(String, String, Message, CorrelationData, Channel)260%80%554411
execute(ChannelCallback, ConnectionFactory)250%20%227711
convertSendAndReceiveRaw(String, String, Object, MessagePostProcessor, CorrelationData)240%20%225511
getReplyToAddress(Message)240%40%336611
addBeforePublishPostProcessors(MessagePostProcessor[])230%20%226611
addAfterReceivePostProcessors(MessagePostProcessor[])230%20%226611
receiveAndConvert(String, long, ParameterizedTypeReference)230%40%334411
cleanUpAfterAction(RabbitResourceHolder, Connection, Channel, ConfirmListener)230%40%339911
stop()220%n/a119911
convertAndSend(String, String, Object, MessagePostProcessor, CorrelationData)220%n/a115511
receiveAndConvert(String, long)220%40%334411
doReceiveAndReply(String, ReceiveAndReplyCallback, ReplyToAddressCallback)210%20%223311
doSendAndReceiveWithFixed(String, String, Message, CorrelationData)200%n/a113311
addConfirmListener(ConfirmCallback, ConfirmCallback, Channel)200%80%555511
receive(String, long)190%n/a114411
doReceiveNoWait(String)180%n/a114411
convertSendAndReceiveAsType(String, String, Object, MessagePostProcessor, CorrelationData, ParameterizedTypeReference)180%20%224411
lambda$doReceiveAndReply$7(String, ReceiveAndReplyCallback, ReplyToAddressCallback, Channel)180%20%224411
setConfirmCallback(RabbitTemplate.ConfirmCallback)170%40%333311
setReturnsCallback(RabbitTemplate.ReturnsCallback)170%40%333311
convertSendAndReceive(String, String, Object, MessagePostProcessor, CorrelationData)170%20%224411
sendToRabbit(Channel, String, String, boolean, Message)170%n/a114411
receive(long)160%20%224411
send(String, String, Message, CorrelationData)150%n/a113311
receive(String)150%20%223311
doSendAndReceiveWithTemporary(String, String, Message, CorrelationData)150%n/a112211
isMandatoryFor(Message)150%20%222211
setBeanFactory(BeanFactory)140%n/a113311
isRunning()140%n/a114411
convertMessageIfNecessary(Object)140%20%223311
setCorrelationKey(String)130%20%224411
removeBeforePublishPostProcessor(MessagePostProcessor)130%20%224411
removeAfterReceivePostProcessor(MessagePostProcessor)130%20%224411
setBeforePublishPostProcessors(MessagePostProcessor[])120%n/a114411
setAfterReceivePostProcessors(MessagePostProcessor[])120%n/a114411
cleanUpAfterAction(Channel, boolean, RabbitResourceHolder, Connection)120%40%336611
isChannelLocallyTransacted(Channel)120%40%331111
getRequiredMessageConverter()120%20%224411
getRequiredQueue()120%20%224411
handleConfirm(PendingConfirm, boolean)120%20%224411
handleReturn(int, String, String, String, AMQP.BasicProperties, byte[])120%n/a112211
convertSendAndReceiveAsType(Object, CorrelationData, ParameterizedTypeReference)110%n/a111111
convertSendAndReceiveAsType(Object, MessagePostProcessor, CorrelationData, ParameterizedTypeReference)110%n/a111111
buildMessageFromResponse(GetResponse)110%n/a112211
lambda$invoke$14(Channel)110%n/a111111
setConnectionFactory(ConnectionFactory)100%20%224411
convertAndSend(Object)100%n/a112211
convertAndSend(Object, MessagePostProcessor, CorrelationData)100%n/a112211
convertSendAndReceive(Object, CorrelationData)100%n/a111111
convertSendAndReceive(Object, MessagePostProcessor, CorrelationData)100%n/a111111
convertSendAndReceiveAsType(String, Object, CorrelationData, ParameterizedTypeReference)100%n/a111111
convertSendAndReceiveAsType(String, Object, MessagePostProcessor, CorrelationData, ParameterizedTypeReference)100%n/a111111
isPublisherConfirmsOrReturns(ConnectionFactory)100%40%331111
buildMessageFromDelivery(Delivery)100%n/a111111
getRequiredSmartMessageConverter()100%n/a113311
lambda$doSendAndReceiveWithFixed$11()100%n/a111111
setMandatoryExpressionString(String)90%n/a113311
getAfterReceivePostProcessors()90%20%223311
getUnconfirmedCount()90%n/a114411
correlationConvertAndSend(Object, CorrelationData)90%n/a112211
convertAndSend(String, Object)90%n/a112211
convertAndSend(String, String, Object, CorrelationData)90%n/a112211
convertAndSend(Object, MessagePostProcessor)90%n/a112211
convertAndSend(String, Object, MessagePostProcessor)90%n/a112211
convertAndSend(String, Object, MessagePostProcessor, CorrelationData)90%n/a112211
sendAndReceive(Message, CorrelationData)90%n/a111111
convertSendAndReceive(String, Object, CorrelationData)90%n/a111111
convertSendAndReceive(String, Object, MessagePostProcessor, CorrelationData)90%n/a111111
convertSendAndReceiveAsType(String, String, Object, ParameterizedTypeReference)90%n/a111111
convertSendAndReceiveAsType(String, String, Object, MessagePostProcessor, ParameterizedTypeReference)90%n/a111111
lambda$doSendAndReceiveWithFixed$12(String, String, Message, CorrelationData, Channel)90%n/a111111
setExchange(String)80%20%222211
setMandatory(boolean)80%n/a112211
evaluateFastReplyTo()80%n/a113311
send(Message)80%n/a112211
send(String, Message, CorrelationData)80%n/a112211
convertAndSend(String, Object, CorrelationData)80%n/a112211
convertAndSend(String, String, Object)80%n/a112211
convertAndSend(String, String, Object, MessagePostProcessor)80%n/a112211
receiveAndReply(ReceiveAndReplyCallback, String, String)80%n/a111111
receiveAndReply(String, ReceiveAndReplyCallback, String, String)80%n/a111111
sendAndReceive(String, Message, CorrelationData)80%n/a111111
convertSendAndReceive(String, String, Object)80%n/a111111
convertSendAndReceive(String, String, Object, CorrelationData)80%n/a111111
convertSendAndReceive(String, String, Object, MessagePostProcessor)80%n/a111111
convertSendAndReceiveAsType(String, Object, ParameterizedTypeReference)80%n/a111111
convertSendAndReceiveAsType(String, Object, MessagePostProcessor, ParameterizedTypeReference)80%n/a111111
lambda$handleReturn$15(RabbitTemplate.PendingReply, ReturnedMessage)80%n/a111111
lambda$consumeDelivery$8(CompletableFuture, ShutdownSignalException)80%20%223311
setReplyAddress(String)70%n/a113311
setMessagePropertiesConverter(MessagePropertiesConverter)70%n/a113311
setMandatoryExpression(Expression)70%n/a113311
addConsumerArg(String, Object)70%n/a112211
send(String, Message)70%n/a112211
send(String, String, Message)70%n/a112211
receiveAndConvert(String, ParameterizedTypeReference)70%n/a111111
receiveAndConvert(long, ParameterizedTypeReference)70%n/a111111
receiveAndReply(String, ReceiveAndReplyCallback)70%n/a111111
receiveAndReply(ReceiveAndReplyCallback, ReplyToAddressCallback)70%n/a111111
sendAndReceive(String, String, Message)70%n/a111111
sendAndReceive(String, String, Message, CorrelationData)70%n/a111111
convertSendAndReceive(String, Object)70%n/a111111
convertSendAndReceive(String, Object, MessagePostProcessor)70%n/a111111
convertSendAndReceiveAsType(Object, ParameterizedTypeReference)70%n/a111111
convertSendAndReceiveAsType(Object, MessagePostProcessor, ParameterizedTypeReference)70%n/a111111
nullSafeExchange(String)70%20%221111
nullSafeRoutingKey(String)70%20%221111
isConfirmListener()70%20%221111
lambda$doSendAndReceiveWithTemporary$9(RabbitTemplate.PendingReply, ShutdownSignalException)70%20%223311
lambda$useDirectReplyTo$2(Channel)70%n/a112211
initDefaultStrategies()60%n/a112211
setUserIdExpressionString(String)60%n/a112211
receiveAndConvert(String)60%n/a111111
receiveAndConvert(long)60%n/a111111
receiveAndConvert(ParameterizedTypeReference)60%n/a111111
receiveAndReply(ReceiveAndReplyCallback)60%n/a111111
receiveAndReply(String, ReceiveAndReplyCallback, ReplyToAddressCallback)60%n/a111111
sendAndReceive(String, Message)60%n/a111111
convertSendAndReceive(Object)60%n/a111111
convertSendAndReceive(Object, MessagePostProcessor)60%n/a111111
execute(ChannelCallback)60%n/a111111
lambda$receiveAndReply$6(String, String, Message, Object)60%n/a111111
removeConsumerArg(String)50%n/a111111
receive()50%n/a111111
receiveAndConvert()50%n/a111111
sendAndReceive(Message)50%n/a111111
cancelConsumerQuietly(Channel, DefaultConsumer)50%n/a112211
onMessage(Message)50%n/a112211
lambda$execute$13(ChannelCallback, ConnectionFactory, RetryContext)50%n/a111111
lambda$getUnconfirmedCount$1(Channel)50%n/a111111
static {...}50%n/a111111
setRoutingKey(String)40%n/a112211
setDefaultReceiveQueue(String)40%n/a112211
setEncoding(String)40%n/a112211
setReceiveTimeout(long)40%n/a112211
setReplyTimeout(long)40%n/a112211
setMessageConverter(MessageConverter)40%n/a112211
setSendConnectionFactorySelectorExpression(Expression)40%n/a112211
setReceiveConnectionFactorySelectorExpression(Expression)40%n/a112211
setRetryTemplate(RetryTemplate)40%n/a112211
setRecoveryCallback(RecoveryCallback)40%n/a112211
setCorrelationDataPostProcessor(CorrelationDataPostProcessor)40%n/a112211
setUseTemporaryReplyQueues(boolean)40%n/a112211
setUseDirectReplyToContainer(boolean)40%n/a112211
setUserIdExpression(Expression)40%n/a112211
setBeanName(String)40%n/a112211
setTaskExecutor(Executor)40%n/a112211
setUserCorrelationId(boolean)40%n/a112211
setUsePublisherConnection(boolean)40%n/a112211
setNoLocalReplyConsumer(boolean)40%n/a112211
setReplyErrorHandler(ErrorHandler)40%n/a112211
setUseChannelForCorrelation(boolean)40%n/a112211
lambda$new$0(Message, Object)40%n/a111111
getExchange()30%n/a111111
getRoutingKey()30%n/a111111
getDefaultReceiveQueue()30%n/a111111
getEncoding()30%n/a111111
getMessagePropertiesConverter()30%n/a111111
getMessageConverter()30%n/a111111
isUsePublisherConnection()30%n/a111111
start()30%n/a112211
destroy()30%n/a112211
getUUID()30%n/a111111
isReturnListener()20%n/a111111
doStart()0%n/a111111
doStop()0%n/a111111
replyTimedOut(String)0%n/a111111