Class AbstractAmqpListenerEndpoint

java.lang.Object

org.springframework.amqp.client.config.AbstractAmqpListenerEndpoint

All Implemented Interfaces:

AmqpListenerEndpoint

Direct Known Subclasses:

MethodAmqpListenerEndpoint, SimpleAmqpListenerEndpoint

public abstract class AbstractAmqpListenerEndpoint
extends Object
implements AmqpListenerEndpoint

The abstract AmqpListenerEndpoint implementation holding common properties.

Since:

4.1

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractAmqpListenerEndpoint(String... addresses)

Method Summary

Modifier and Type	Method	Description
String[]	getAddresses()	Return the AMQP addresses to listen to.
org.aopalliance.aop.Advice @Nullable []	getAdviceChain()	The advice chain for the target listener container bean.
@Nullable Boolean	getAutoAccept()	Override the autoAccept property in the AmqpMessageListenerContainerFactory.
@Nullable Boolean	getAutoStartup()	Override of the default autoStartup property from the AmqpMessageListenerContainerFactory.
@Nullable Integer	getConcurrency()	Return the concurrency (consumers per AMQP address) for the target listener container bean.
@Nullable Duration	getGracefulShutdownPeriod()	The graceful shutdown period for the target listener container bean.
@Nullable String	getId()	Return the id of the target listener container bean.
@Nullable Integer	getInitialCredits()	The initial number of credits to grant to the AMQP receiver.
@Nullable Duration	getReceiveTimeout()	The receiveTimeout for the target listener container bean.
@Nullable Executor	getTaskExecutor()	Get the task executor for the target listener container bean.
void	setAdviceChain(org.aopalliance.aop.Advice... adviceChain)
void	setAutoAccept(boolean autoAccept)
void	setAutoStartup(boolean autoStartup)
void	setConcurrency(int concurrency)
void	setGracefulShutdownPeriod(Duration gracefulShutdownPeriod)
void	setId(String id)
void	setInitialCredits(int initialCredits)
void	setReceiveTimeout(Duration receiveTimeout)
void	setTaskExecutor(Executor taskExecutor)

Methods inherited from class Object

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

Methods inherited from interface AmqpListenerEndpoint

getMessageListener

Constructor Details

AbstractAmqpListenerEndpoint

protected AbstractAmqpListenerEndpoint(String... addresses)

Method Details

getAddresses

public String[] getAddresses()

Description copied from interface: AmqpListenerEndpoint

Return the AMQP addresses to listen to.

Specified by:

getAddresses in interface AmqpListenerEndpoint

Returns:

the addresses.

setId

public void setId(String id)

getId

public @Nullable String getId()

Description copied from interface: AmqpListenerEndpoint

Return the id of the target listener container bean. If not provided, the AmqpListenerEndpointRegistry makes a decision about generated bean name.

Specified by:

getId in interface AmqpListenerEndpoint

Returns:

the id

setConcurrency

public void setConcurrency(int concurrency)

getConcurrency

public @Nullable Integer getConcurrency()

Description copied from interface: AmqpListenerEndpoint

Return the concurrency (consumers per AMQP address) for the target listener container bean. The AmqpMessageListenerContainerFactory configuration is used by default.

Specified by:

getConcurrency in interface AmqpListenerEndpoint

Returns:

the concurrency

setAutoStartup

public void setAutoStartup(boolean autoStartup)

getAutoStartup

public @Nullable Boolean getAutoStartup()

Description copied from interface: AmqpListenerEndpoint

Override of the default autoStartup property from the AmqpMessageListenerContainerFactory.

Specified by:

getAutoStartup in interface AmqpListenerEndpoint

Returns:

the autoStartup.

setTaskExecutor

public void setTaskExecutor(Executor taskExecutor)

getTaskExecutor

public @Nullable Executor getTaskExecutor()

Description copied from interface: AmqpListenerEndpoint

Get the task executor for the target listener container bean. Overrides any executor set on the AmqpMessageListenerContainerFactory.

Specified by:

getTaskExecutor in interface AmqpListenerEndpoint

Returns:

the executor.

setAutoAccept

public void setAutoAccept(boolean autoAccept)

getAutoAccept

public @Nullable Boolean getAutoAccept()

Description copied from interface: AmqpListenerEndpoint

Override the autoAccept property in the AmqpMessageListenerContainerFactory.

Specified by:

getAutoAccept in interface AmqpListenerEndpoint

Returns:

true if auto-accept is enabled.

setInitialCredits

public void setInitialCredits(int initialCredits)

getInitialCredits

public @Nullable Integer getInitialCredits()

Description copied from interface: AmqpListenerEndpoint

The initial number of credits to grant to the AMQP receiver. Override the initialCredits property in the AmqpMessageListenerContainerFactory.

Specified by:

getInitialCredits in interface AmqpListenerEndpoint

Returns:

number of initial credits

setReceiveTimeout

public void setReceiveTimeout(Duration receiveTimeout)

getReceiveTimeout

public @Nullable Duration getReceiveTimeout()

Description copied from interface: AmqpListenerEndpoint

The receiveTimeout for the target listener container bean.

Specified by:

getReceiveTimeout in interface AmqpListenerEndpoint

Returns:

the timeout for receiving messages.

setGracefulShutdownPeriod

public void setGracefulShutdownPeriod(Duration gracefulShutdownPeriod)

getGracefulShutdownPeriod

public @Nullable Duration getGracefulShutdownPeriod()

Description copied from interface: AmqpListenerEndpoint

The graceful shutdown period for the target listener container bean.

Specified by:

getGracefulShutdownPeriod in interface AmqpListenerEndpoint

Returns:

the graceful shutdown period.

setAdviceChain

public void setAdviceChain(org.aopalliance.aop.Advice... adviceChain)

getAdviceChain

public org.aopalliance.aop.Advice @Nullable [] getAdviceChain()

Description copied from interface: AmqpListenerEndpoint

The advice chain for the target listener container bean.

Specified by:

getAdviceChain in interface AmqpListenerEndpoint

Returns:

the advice chain.