Class SimpleRabbitListenerEndpoint

java.lang.Object
org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint
org.springframework.amqp.rabbit.config.SimpleRabbitListenerEndpoint
All Implemented Interfaces:
RabbitListenerEndpoint, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware

public class SimpleRabbitListenerEndpoint extends AbstractRabbitListenerEndpoint
A RabbitListenerEndpoint simply providing the MessageListener to invoke to process an incoming message for this endpoint.
Since:
1.4
  • Constructor Details

    • SimpleRabbitListenerEndpoint

      public SimpleRabbitListenerEndpoint()
  • Method Details

    • setMessageListener

      public void setMessageListener(org.springframework.amqp.core.MessageListener messageListener)
      Set the MessageListener to invoke when a message matching the endpoint is received.
      Parameters:
      messageListener - the MessageListener instance.
    • getMessageListener

      public org.springframework.amqp.core.MessageListener getMessageListener()
      Returns:
      the MessageListener to invoke when a message matching the endpoint is received.
    • createMessageListener

      protected org.springframework.amqp.core.MessageListener createMessageListener(MessageListenerContainer container)
      Description copied from class: AbstractRabbitListenerEndpoint
      Create a MessageListener that is able to serve this endpoint for the specified container.
      Specified by:
      createMessageListener in class AbstractRabbitListenerEndpoint
      Parameters:
      container - the MessageListenerContainer to create a MessageListener.
      Returns:
      a a MessageListener instance.
    • getEndpointDescription

      protected StringBuilder getEndpointDescription()
      Overrides:
      getEndpointDescription in class AbstractRabbitListenerEndpoint
      Returns:
      a description for this endpoint.

      Available to subclasses, for inclusion in their toString() result.