Class JmsListenerContainerSpec<S extends JmsListenerContainerSpec<S,C>, C extends AbstractMessageListenerContainer>

java.lang.Object

org.springframework.integration.dsl.IntegrationComponentSpec<S,C>

org.springframework.integration.jms.dsl.JmsDestinationAccessorSpec<S,C>

org.springframework.integration.jms.dsl.JmsListenerContainerSpec<S,C>

Type Parameters:

S - the target JmsListenerContainerSpec implementation type.

C - the target AbstractMessageListenerContainer implementation type.

All Implemented Interfaces:

DisposableBean, FactoryBean<C>, InitializingBean, Lifecycle, Phased, SmartLifecycle

Direct Known Subclasses:

JmsDefaultListenerContainerSpec

public class JmsListenerContainerSpec<S extends JmsListenerContainerSpec<S,C>, C extends AbstractMessageListenerContainer>
extends JmsDestinationAccessorSpec<S,C>

A JmsDestinationAccessorSpec for JmsListenerContainerSpecs.

Since:

5.0

Author:

Artem Bilan, Gary Russell

Field Summary

Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

logger, PARSER, target

Fields inherited from interface org.springframework.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Fields inherited from interface org.springframework.context.SmartLifecycle

DEFAULT_PHASE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	JmsListenerContainerSpec(Class<C> aClass)

Method Summary

Modifier and Type	Method	Description
S	acceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)
S	clientId(String clientId)
S	durableSubscriptionName(String durableSubscriptionName)
S	errorHandler(ErrorHandler errorHandler)
S	exceptionListener(ExceptionListener exceptionListener)
S	exposeListenerSession(boolean exposeListenerSession)
S	messageSelector(String messageSelector)
S	observationRegistry(io.micrometer.observation.ObservationRegistry observationRegistry)	Configure an ObservationRegistry to use in the target listener container.
S	subscriptionDurable(boolean subscriptionDurable)
S	subscriptionShared(boolean subscriptionShared)	Set whether to make the subscription shared.

Methods inherited from class org.springframework.integration.jms.dsl.JmsDestinationAccessorSpec

connectionFactory, destinationResolver, id, pubSubDomain, sessionAcknowledgeMode, sessionAcknowledgeModeName, sessionTransacted

Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec

_this, afterPropertiesSet, destroy, doGet, getId, getObject, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.beans.factory.FactoryBean

isSingleton

Methods inherited from interface org.springframework.context.SmartLifecycle

isPauseable

Constructor Details

JmsListenerContainerSpec

protected JmsListenerContainerSpec(Class<C> aClass)

Method Details

messageSelector

public S messageSelector(String messageSelector)

Parameters:

messageSelector - the messageSelector.

Returns:

the spec.

See Also:

• AbstractMessageListenerContainer.setMessageSelector(String)

subscriptionDurable

public S subscriptionDurable(boolean subscriptionDurable)

Parameters:

subscriptionDurable - the subscriptionDurable.

Returns:

the spec.

See Also:

• AbstractMessageListenerContainer.setSubscriptionDurable(boolean)

durableSubscriptionName

public S durableSubscriptionName(String durableSubscriptionName)

Parameters:

durableSubscriptionName - the durableSubscriptionName.

Returns:

the spec.

See Also:

• AbstractMessageListenerContainer.setDurableSubscriptionName(String)

subscriptionShared

public S subscriptionShared(boolean subscriptionShared)

Set whether to make the subscription shared.

Parameters:

subscriptionShared - make the subscription shared or not.

Returns:

the spec.

Since:

5.0.7

See Also:

• AbstractMessageListenerContainer.setSubscriptionShared(boolean)

exceptionListener

public S exceptionListener(ExceptionListener exceptionListener)

Parameters:

exceptionListener - the exceptionListener.

Returns:

the spec.

See Also:

• AbstractMessageListenerContainer.setExceptionListener(ExceptionListener)

errorHandler

public S errorHandler(ErrorHandler errorHandler)

Parameters:

errorHandler - the errorHandler.

Returns:

the spec.

See Also:

• AbstractMessageListenerContainer.setErrorHandler(ErrorHandler)

exposeListenerSession

public S exposeListenerSession(boolean exposeListenerSession)

Parameters:

exposeListenerSession - the exposeListenerSession.

Returns:

the spec.

See Also:

• AbstractMessageListenerContainer.setExposeListenerSession(boolean)

acceptMessagesWhileStopping

public S acceptMessagesWhileStopping(boolean acceptMessagesWhileStopping)

Parameters:

acceptMessagesWhileStopping - the acceptMessagesWhileStopping.

Returns:

the spec.

See Also:

• AbstractMessageListenerContainer.setAcceptMessagesWhileStopping(boolean)

clientId

public S clientId(String clientId)

Parameters:

clientId - the clientId.

Returns:

the spec.

See Also:

• AbstractJmsListeningContainer.setClientId(String)

observationRegistry

public S observationRegistry(io.micrometer.observation.ObservationRegistry observationRegistry)

Configure an ObservationRegistry to use in the target listener container.

Parameters:

observationRegistry - the observationRegistry.

Returns:

the spec.

Since:

6.2

See Also:

• AbstractMessageListenerContainer.setObservationRegistry(ObservationRegistry)