Package io.awspring.cloud.sqs.config

Class AbstractEndpoint

java.lang.Object

io.awspring.cloud.sqs.config.AbstractEndpoint

All Implemented Interfaces:

Endpoint, HandlerMethodEndpoint

Direct Known Subclasses:

SqsEndpoint

public abstract class AbstractEndpoint
extends Object
implements HandlerMethodEndpoint

Base class for implementing a HandlerMethodEndpoint.

Since:

3.0

Author:

Tomaz Fernandes

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractEndpoint(Collection<String> queueNames, String listenerContainerFactoryName, String id)

Method Summary

Modifier and Type	Method	Description
void	configureListenerMode(Consumer<ListenerMode> consumer)	Allows configuring the ListenerMode for this endpoint.
protected <T> AsyncMessageListener<T>	createAsyncMessageListenerInstance(InvocableHandlerMethod handlerMethod)
protected <T> MessageListener<T>	createMessageListenerInstance(InvocableHandlerMethod handlerMethod)
String	getId()	An optional id for this endpoint.
String	getListenerContainerFactoryName()	The name of the factory bean that will process this endpoint.
Collection<String>	getLogicalNames()	The logical names for this endpoint.
void	setBean(Object bean)	Set the bean instance to be used when handling a message for this endpoint.
void	setHandlerMethodFactory(MessageHandlerMethodFactory handlerMethodFactory)	Set the MessageHandlerMethodFactory to be used for handling messages in this endpoint.
void	setMethod(Method method)	Set the method to be used when handling a message for this endpoint.
<T> void	setupContainer(MessageListenerContainer<T> container)	Configure the provided container for this endpoint.

Methods inherited from class java.lang.Object

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

Constructor Details

AbstractEndpoint

protected AbstractEndpoint(Collection<String> queueNames,
 @Nullable
 String listenerContainerFactoryName,
 String id)

Method Details

getLogicalNames

public Collection<String> getLogicalNames()

Description copied from interface: Endpoint

The logical names for this endpoint.

Specified by:

getLogicalNames in interface Endpoint

Returns:

the logical names.

getListenerContainerFactoryName

public String getListenerContainerFactoryName()

Description copied from interface: Endpoint

The name of the factory bean that will process this endpoint.

Specified by:

getListenerContainerFactoryName in interface Endpoint

Returns:

the factory bean name.

getId

public String getId()

Description copied from interface: Endpoint

An optional id for this endpoint.

Specified by:

getId in interface Endpoint

Returns:

the endpoint id.

setBean

public void setBean(Object bean)

Set the bean instance to be used when handling a message for this endpoint.

Specified by:

setBean in interface HandlerMethodEndpoint

Parameters:

bean - the bean instance.

setMethod

public void setMethod(Method method)

Set the method to be used when handling a message for this endpoint.

Specified by:

setMethod in interface HandlerMethodEndpoint

Parameters:

method - the method.

setHandlerMethodFactory

public void setHandlerMethodFactory(MessageHandlerMethodFactory handlerMethodFactory)

Set the MessageHandlerMethodFactory to be used for handling messages in this endpoint.

Specified by:

setHandlerMethodFactory in interface HandlerMethodEndpoint

Parameters:

handlerMethodFactory - the factory.

configureListenerMode

public void configureListenerMode(Consumer<ListenerMode> consumer)

Description copied from interface: HandlerMethodEndpoint

Allows configuring the ListenerMode for this endpoint.

Specified by:

configureListenerMode in interface HandlerMethodEndpoint

Parameters:

consumer - a consumer for the strategy used by this endpoint.

setupContainer

public <T> void setupContainer(MessageListenerContainer<T> container)

Configure the provided container for this endpoint.

Specified by:

setupContainer in interface Endpoint

Parameters:

container - the container to be configured.

createMessageListenerInstance

protected <T> MessageListener<T> createMessageListenerInstance(InvocableHandlerMethod handlerMethod)

createAsyncMessageListenerInstance

protected <T> AsyncMessageListener<T> createAsyncMessageListenerInstance(InvocableHandlerMethod handlerMethod)