Class MethodAmqpMessageListenerContainerFactory

java.lang.Object

org.springframework.amqp.client.config.AmqpMessageListenerContainerFactory

org.springframework.amqp.client.config.MethodAmqpMessageListenerContainerFactory

All Implemented Interfaces:

Aware, BeanFactoryAware

public class MethodAmqpMessageListenerContainerFactory
extends AmqpMessageListenerContainerFactory
implements BeanFactoryAware

The AmqpMessageListenerContainerFactory extension for MethodAmqpListenerEndpoint.

The MethodAmqpListenerEndpoint-related properties of this factory serve as defaults values if they are not provided on the MethodAmqpListenerEndpoint.

Delegates to super class if provided endpoint is not a MethodAmqpListenerEndpoint.

Since:

4.1

Author:

Artem Bilan

See Also:

• MethodAmqpListenerEndpoint

Constructor Summary

Constructors

Constructor	Description
MethodAmqpMessageListenerContainerFactory(AmqpConnectionFactory connectionFactory)	Create an instance with the provided AmqpConnectionFactory.

Method Summary

Modifier and Type	Method	Description
protected void	configureEndpoint(AmqpListenerEndpoint endpoint)
void	setBeanFactory(BeanFactory beanFactory)
void	setCharset(Charset charset)	Set a charset for byte[] to String method argument conversion.
void	setCustomMethodArgumentResolvers(HandlerMethodArgumentResolver... methodArgumentResolvers)	Add custom methods arguments resolvers the default message handler factory.
void	setDefaultRequeueRejected(boolean defaultRequeueRejected)	Set the default behavior for messages rejection, for example, when the listener threw an exception.
void	setHeaderMapper(AmqpHeaderMapper headerMapper)	Set the AmqpHeaderMapper implementation to use to map the standard AMQP headers.
void	setListenerErrorHandler(AmqpListenerErrorHandler errorHandler)	Set the AmqpListenerErrorHandler to invoke if the listener method throws an exception.
void	setMessageConverter(MessageConverter messageConverter)	Set the converter to convert incoming messages to listener method arguments, and objects returned from listener methods for response messages.
void	setMessageHandlerMethodFactory(MessageHandlerMethodFactory messageHandlerMethodFactory)	Set the MessageHandlerMethodFactory to configure MethodAmqpListenerEndpoint.
void	setReplyContentType(String replyContentType)	Set the reply content type.
void	setReplyPostProcessor(ReplyPostProcessor replyPostProcessor)	Set a ReplyPostProcessor to post process a response message before it is sent.
void	setReturnExceptions(boolean returnExceptions)	Set whether exceptions thrown by the listener should be returned as a response message body to the sender using the normal replyTo/@SendTo semantics.
void	setValidator(Validator validator)	Set the validator to use if the default message handler factory is used.

Methods inherited from class AmqpMessageListenerContainerFactory

createContainer, setAdviceChain, setAutoAccept, setAutoStartup, setConcurrency, setErrorHandler, setGracefulShutdownPeriod, setInitialCredits, setReceiveTimeout, setRecoveryBackOff, setRecoveryInterval, setTaskExecutor

Methods inherited from class Object

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

Constructor Details

MethodAmqpMessageListenerContainerFactory

public MethodAmqpMessageListenerContainerFactory(AmqpConnectionFactory connectionFactory)

Create an instance with the provided AmqpConnectionFactory.

Parameters:

connectionFactory - the connection factory to use.

Method Details

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)
                    throws BeansException

Specified by:

setBeanFactory in interface BeanFactoryAware

Throws:

BeansException

setDefaultRequeueRejected

public void setDefaultRequeueRejected(boolean defaultRequeueRejected)

Set the default behavior for messages rejection, for example, when the listener threw an exception. When true (default), messages will be requeued, otherwise - rejected. Setting to false causes all rejections to not be requeued. When set to true, the default can be overridden by the listener throwing an AmqpRejectAndDontRequeueException.

Parameters:

defaultRequeueRejected - false to reject messages by default.

See Also:

• MethodAmqpListenerEndpoint.setDefaultRequeueRejected(boolean)

setReturnExceptions

public void setReturnExceptions(boolean returnExceptions)

Set whether exceptions thrown by the listener should be returned as a response message body to the sender using the normal replyTo/@SendTo semantics.

Parameters:

returnExceptions - true to return exceptions.

See Also:

• MethodAmqpListenerEndpoint.setReturnExceptions(boolean)

setReplyPostProcessor

public void setReplyPostProcessor(ReplyPostProcessor replyPostProcessor)

Set a ReplyPostProcessor to post process a response message before it is sent.

Parameters:

replyPostProcessor - the post-processor.

See Also:

• MethodAmqpListenerEndpoint.setReplyPostProcessor(ReplyPostProcessor)

setListenerErrorHandler

public void setListenerErrorHandler(AmqpListenerErrorHandler errorHandler)

Set the AmqpListenerErrorHandler to invoke if the listener method throws an exception.

Parameters:

errorHandler - the error handler.

See Also:

• MethodAmqpListenerEndpoint.setErrorHandler(AmqpListenerErrorHandler)

setReplyContentType

public void setReplyContentType(String replyContentType)

Set the reply content type. Overrides the one populated by a message converter.

Parameters:

replyContentType - the content type.

See Also:

• MethodAmqpListenerEndpoint.setReplyContentType(String)

setHeaderMapper

public void setHeaderMapper(AmqpHeaderMapper headerMapper)

Set the AmqpHeaderMapper implementation to use to map the standard AMQP headers.

Parameters:

headerMapper - the AmqpHeaderMapper instance.

See Also:

• MethodAmqpListenerEndpoint.setHeaderMapper(AmqpHeaderMapper)

setMessageConverter

public void setMessageConverter(MessageConverter messageConverter)

Set the converter to convert incoming messages to listener method arguments, and objects returned from listener methods for response messages.

Parameters:

messageConverter - The message converter.

See Also:

• MethodAmqpListenerEndpoint.setMessageConverter(MessageConverter)

setCharset

public void setCharset(Charset charset)

Set a charset for byte[] to String method argument conversion.

Parameters:

charset - the charset (default UTF-8).

See Also:

• setMessageHandlerMethodFactory(MessageHandlerMethodFactory)

setValidator

public void setValidator(Validator validator)

Set the validator to use if the default message handler factory is used.

Parameters:

validator - the validator.

See Also:

• setMessageHandlerMethodFactory(MessageHandlerMethodFactory)

setCustomMethodArgumentResolvers

public void setCustomMethodArgumentResolvers(HandlerMethodArgumentResolver... methodArgumentResolvers)

Add custom methods arguments resolvers the default message handler factory. Default empty list.

Parameters:

methodArgumentResolvers - the methodArgumentResolvers to assign.

See Also:

• setMessageHandlerMethodFactory(MessageHandlerMethodFactory)

setMessageHandlerMethodFactory

public void setMessageHandlerMethodFactory(MessageHandlerMethodFactory messageHandlerMethodFactory)

Set the MessageHandlerMethodFactory to configure MethodAmqpListenerEndpoint.

By default, an AmqpMessageHandlerMethodFactory is used, and it can be configured further to support additional method arguments or to customize conversion and validation support. See DefaultMessageHandlerMethodFactory Javadoc for more details.

Parameters:

messageHandlerMethodFactory - the MessageHandlerMethodFactory instance.

See Also:

• AmqpMessageHandlerMethodFactory

configureEndpoint

protected void configureEndpoint(AmqpListenerEndpoint endpoint)

Overrides:

configureEndpoint in class AmqpMessageListenerContainerFactory