org.springframework.amqp.rabbit.test

Class TestRabbitTemplate

java.lang.Object

org.springframework.amqp.rabbit.connection.RabbitAccessor

org.springframework.amqp.rabbit.core.RabbitTemplate

org.springframework.amqp.rabbit.test.TestRabbitTemplate

All Implemented Interfaces:

AmqpTemplate, MessageListener, RabbitOperations, ListenerContainerAware, PublisherCallbackChannel.Listener, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.SmartInitializingSingleton, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle

public class TestRabbitTemplate
extends RabbitTemplate
implements org.springframework.context.ApplicationContextAware, org.springframework.beans.factory.SmartInitializingSingleton

A RabbitTemplate that invokes @RabbitListener s directly. It currently only supports the queue name in the routing key. It does not currently support publisher confirms/returns.

Since:

2.0

Author:

Gary Russell

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.amqp.rabbit.core.RabbitTemplate

RabbitTemplate.ConfirmCallback, RabbitTemplate.ReturnCallback, RabbitTemplate.TemplateConsumer

Nested classes/interfaces inherited from interface org.springframework.amqp.rabbit.core.RabbitOperations

RabbitOperations.OperationsCallback<T>

Field Summary

Fields inherited from class org.springframework.amqp.rabbit.connection.RabbitAccessor

logger

Constructor Summary

Constructors

Constructor and Description
TestRabbitTemplate(ConnectionFactory connectionFactory)

Method Summary

Modifier and Type	Method and Description
void	afterSingletonsInstantiated()
protected Message	doSendAndReceiveWithFixed(String exchange, String routingKey, Message message, CorrelationData correlationData)
protected void	sendToRabbit(com.rabbitmq.client.Channel channel, String exchange, String routingKey, boolean mandatory, Message message)
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
protected boolean	useDirectReplyTo() Override this method use some other criteria to decide whether or not to use direct reply-to (https://www.rabbitmq.com/direct-reply-to.html).

Methods inherited from class org.springframework.amqp.rabbit.core.RabbitTemplate

addListener, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertAndSend, convertMessageIfNecessary, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceive, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveAsType, convertSendAndReceiveRaw, correlationConvertAndSend, determineConfirmsReturnsCapability, doReceiveNoWait, doSend, doSendAndReceive, doSendAndReceiveWithTemporary, doStart, doStop, execute, expectedQueueNames, getEncoding, getExchange, getMessageConverter, getMessagePropertiesConverter, getRoutingKey, getUnconfirmed, getUnconfirmedCount, getUUID, handleConfirm, handleReturn, initDefaultStrategies, invoke, isChannelLocallyTransacted, isConfirmListener, isMandatoryFor, isReturnListener, isRunning, onMessage, receive, receive, receive, receive, receiveAndConvert, receiveAndConvert, receiveAndConvert, receiveAndConvert, receiveAndConvert, receiveAndConvert, receiveAndConvert, receiveAndConvert, receiveAndReply, receiveAndReply, receiveAndReply, receiveAndReply, receiveAndReply, receiveAndReply, revoke, send, send, send, send, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, sendAndReceive, setAfterReceivePostProcessors, setBeanFactory, setBeanName, setBeforePublishPostProcessors, setConfirmCallback, setCorrelationDataPostProcessor, setCorrelationKey, setEncoding, setExchange, setMandatory, setMandatoryExpression, setMandatoryExpressionString, setMessageConverter, setMessagePropertiesConverter, setQueue, setReceiveConnectionFactorySelectorExpression, setReceiveTimeout, setRecoveryCallback, setReplyAddress, setReplyTimeout, setRetryTemplate, setReturnCallback, setRoutingKey, setSendConnectionFactorySelectorExpression, setTaskExecutor, setUseDirectReplyToContainer, setUserIdExpression, setUserIdExpressionString, setUseTemporaryReplyQueues, start, stop, waitForConfirms, waitForConfirmsOrDie

Methods inherited from class org.springframework.amqp.rabbit.connection.RabbitAccessor

afterPropertiesSet, convertRabbitAccessException, createConnection, getChannel, getConnection, getConnectionFactory, getTransactionalResourceHolder, isChannelTransacted, setChannelTransacted, setConnectionFactory

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.amqp.rabbit.core.RabbitOperations

getConnectionFactory

Constructor Detail

TestRabbitTemplate

public TestRabbitTemplate(ConnectionFactory connectionFactory)

Method Detail

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
                           throws org.springframework.beans.BeansException

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.BeansException

afterSingletonsInstantiated

public void afterSingletonsInstantiated()

Specified by:

afterSingletonsInstantiated in interface org.springframework.beans.factory.SmartInitializingSingleton

useDirectReplyTo

protected boolean useDirectReplyTo()

Description copied from class: RabbitTemplate

Override this method use some other criteria to decide whether or not to use direct reply-to (https://www.rabbitmq.com/direct-reply-to.html). The default implementation returns true if the broker supports it and there is no replyAddress set and useTemporaryReplyQueues is false. When direct reply-to is not used, the template will create a temporary, exclusive, auto-delete queue for the reply.

This method is invoked once only - when the first message is sent, from a synchronized block.

Overrides:

useDirectReplyTo in class RabbitTemplate

Returns:

true to use direct reply-to.

sendToRabbit

protected void sendToRabbit(com.rabbitmq.client.Channel channel,
                            String exchange,
                            String routingKey,
                            boolean mandatory,
                            Message message)
                     throws IOException

Overrides:

sendToRabbit in class RabbitTemplate

Throws:

IOException

doSendAndReceiveWithFixed

protected Message doSendAndReceiveWithFixed(String exchange,
                                            String routingKey,
                                            Message message,
                                            CorrelationData correlationData)

Overrides:

doSendAndReceiveWithFixed in class RabbitTemplate