org.springframework.amqp.rabbit.listener

Class MethodRabbitListenerEndpoint

java.lang.Object

org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint

org.springframework.amqp.rabbit.listener.MethodRabbitListenerEndpoint

All Implemented Interfaces:

RabbitListenerEndpoint, Aware, BeanFactoryAware

Direct Known Subclasses:

MultiMethodRabbitListenerEndpoint

public class MethodRabbitListenerEndpoint
extends AbstractRabbitListenerEndpoint

A RabbitListenerEndpoint providing the method to invoke to process an incoming message for this endpoint.

Since:

1.4

Author:

Stephane Nicoll, Artem Bilan, Gary Russell

Constructor Summary

Constructors

Constructor and Description
MethodRabbitListenerEndpoint()

Method Summary

Modifier and Type	Method and Description
protected HandlerAdapter	configureListenerAdapter(MessagingMessageListenerAdapter messageListener) Create a HandlerAdapter for this listener adapter.
protected MessagingMessageListenerAdapter	createMessageListener(MessageListenerContainer container) Create a MessageListener that is able to serve this endpoint for the specified container.
protected MessagingMessageListenerAdapter	createMessageListenerInstance() Create an empty MessagingMessageListenerAdapter instance.
Object	getBean()
protected StringBuilder	getEndpointDescription()
protected MessageHandlerMethodFactory	getMessageHandlerMethodFactory()
Method	getMethod()
void	setBean(Object bean) Set the object instance that should manage this endpoint.
void	setErrorHandler(RabbitListenerErrorHandler errorHandler) Set the RabbitListenerErrorHandler to invoke if the listener method throws an exception.
void	setMessageHandlerMethodFactory(MessageHandlerMethodFactory messageHandlerMethodFactory) Set the MessageHandlerMethodFactory to use to build the InvocableHandlerMethod responsible to manage the invocation of this endpoint.
void	setMethod(Method method) Set the method to invoke to process a message managed by this endpoint.
void	setReturnExceptions(boolean returnExceptions) Set whether exceptions thrown by the listener should be returned to the sender using the normal replyTo/@SendTo semantics.

Methods inherited from class org.springframework.amqp.rabbit.listener.AbstractRabbitListenerEndpoint

getAckMode, getAdmin, getAutoStartup, getBatchingStrategy, getBeanExpressionContext, getBeanFactory, getBeanResolver, getConcurrency, getGroup, getId, getMessageConverter, getPriority, getQueueNames, getQueues, getReplyPostProcessor, getResolver, getTaskExecutor, isBatchListener, isExclusive, setAckMode, setAdmin, setAutoStartup, setBatchingStrategy, setBatchListener, setBeanFactory, setConcurrency, setExclusive, setGroup, setId, setMessageConverter, setPriority, setQueueNames, setQueues, setReplyPostProcessor, setTaskExecutor, setupListenerContainer, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

MethodRabbitListenerEndpoint

public MethodRabbitListenerEndpoint()

Method Detail

setBean

public void setBean(Object bean)

Set the object instance that should manage this endpoint.

Parameters:

bean - the target bean instance.

getBean

public Object getBean()

setMethod

public void setMethod(Method method)

Set the method to invoke to process a message managed by this endpoint.

Parameters:

method - the target method for the bean.

getMethod

public Method getMethod()

setMessageHandlerMethodFactory

public void setMessageHandlerMethodFactory(MessageHandlerMethodFactory messageHandlerMethodFactory)

Set the MessageHandlerMethodFactory to use to build the InvocableHandlerMethod responsible to manage the invocation of this endpoint.

Parameters:

messageHandlerMethodFactory - the MessageHandlerMethodFactory instance.

setReturnExceptions

public void setReturnExceptions(boolean returnExceptions)

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

Parameters:

returnExceptions - true to return exceptions.

Since:

2.0

setErrorHandler

public void setErrorHandler(RabbitListenerErrorHandler errorHandler)

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

Parameters:

errorHandler - the error handler.

Since:

2.0

getMessageHandlerMethodFactory

protected MessageHandlerMethodFactory getMessageHandlerMethodFactory()

Returns:

the messageHandlerMethodFactory

createMessageListener

protected MessagingMessageListenerAdapter 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.

configureListenerAdapter

protected HandlerAdapter configureListenerAdapter(MessagingMessageListenerAdapter messageListener)

Create a HandlerAdapter for this listener adapter.

Parameters:

messageListener - the listener adapter.

Returns:

the handler adapter.

createMessageListenerInstance

protected MessagingMessageListenerAdapter createMessageListenerInstance()

Create an empty MessagingMessageListenerAdapter instance.

Returns:

the MessagingMessageListenerAdapter 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.