Class MethodAmqpMessageListenerContainerFactory

java.lang.Object
org.springframework.amqp.client.config.AmqpMessageListenerContainerFactory
org.springframework.amqp.client.config.MethodAmqpMessageListenerContainerFactory
All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware
public class MethodAmqpMessageListenerContainerFactory extends AmqpMessageListenerContainerFactory implements org.springframework.beans.factory.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
See Also:

  • 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(org.springframework.beans.factory.BeanFactory beanFactory) throws org.springframework.beans.BeansException
      Specified by:
      setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAware
      Throws:
      org.springframework.beans.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:

    • 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:

    • setReplyPostProcessor

      public void setReplyPostProcessor(org.springframework.amqp.listener.adapter.ReplyPostProcessor replyPostProcessor)
      Set a ReplyPostProcessor to post process a response message before it is sent.
      Parameters:
      replyPostProcessor - the post-processor.
      See Also:

    • 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:

    • 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:

    • setHeaderMapper

      public void setHeaderMapper(org.springframework.amqp.support.AmqpHeaderMapper headerMapper)
      Set the AmqpHeaderMapper implementation to use to map the standard AMQP headers.
      Parameters:
      headerMapper - the AmqpHeaderMapper instance.
      See Also:

    • setMessageConverter

      public void setMessageConverter(org.springframework.amqp.support.converter.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:

    • 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:

    • setValidator

      public void setValidator(org.springframework.validation.Validator validator)
      Set the validator to use if the default message handler factory is used.
      Parameters:
      validator - the validator.
      See Also:

    • setCustomMethodArgumentResolvers

      public void setCustomMethodArgumentResolvers(org.springframework.messaging.handler.invocation.HandlerMethodArgumentResolver... methodArgumentResolvers)
      Add custom methods arguments resolvers the default message handler factory. Default empty list.
      Parameters:
      methodArgumentResolvers - the methodArgumentResolvers to assign.
      See Also:

    • setMessageHandlerMethodFactory

      public void setMessageHandlerMethodFactory(org.springframework.messaging.handler.annotation.support.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