Class AbstractJmsListenerContainerFactory<C extends AbstractMessageListenerContainer>

java.lang.Object

org.springframework.jms.config.AbstractJmsListenerContainerFactory<C>

Type Parameters:

C - the container type

All Implemented Interfaces:

JmsListenerContainerFactory<C>

Direct Known Subclasses:

DefaultJmsListenerContainerFactory, SimpleJmsListenerContainerFactory

public abstract class AbstractJmsListenerContainerFactory<C extends AbstractMessageListenerContainer>
extends Object
implements JmsListenerContainerFactory<C>

Base JmsListenerContainerFactory for Spring's base container implementation.

Since:

4.1

Author:

Stephane Nicoll

See Also:

• AbstractMessageListenerContainer

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.apache.commons.logging.Log	logger

Constructor Summary

Constructors

Constructor	Description
AbstractJmsListenerContainerFactory()

Method Summary

Modifier and Type	Method	Description
protected abstract C	createContainerInstance()	Create an empty container instance.
C	createListenerContainer(JmsListenerEndpoint endpoint)	Create a MessageListenerContainer for the given JmsListenerEndpoint.
protected void	initializeContainer(C instance)	Further initialize the specified container.
void	setAcknowledgeAfterListener(Boolean acknowledgeAfterListener)
void	setAutoStartup(boolean autoStartup)
void	setClientId(String clientId)
void	setConnectionFactory(jakarta.jms.ConnectionFactory connectionFactory)
void	setDestinationResolver(DestinationResolver destinationResolver)
void	setErrorHandler(ErrorHandler errorHandler)
void	setExceptionListener(jakarta.jms.ExceptionListener exceptionListener)
void	setMessageConverter(MessageConverter messageConverter)
void	setObservationRegistry(io.micrometer.observation.ObservationRegistry observationRegistry)	Set the ObservationRegistry to be used for recording JMS message processing observations.
void	setPhase(int phase)
void	setPubSubDomain(Boolean pubSubDomain)
void	setReplyPubSubDomain(Boolean replyPubSubDomain)
void	setReplyQosSettings(QosSettings replyQosSettings)
void	setSessionAcknowledgeMode(Integer sessionAcknowledgeMode)
void	setSessionTransacted(Boolean sessionTransacted)
void	setSubscriptionDurable(Boolean subscriptionDurable)
void	setSubscriptionShared(Boolean subscriptionShared)

Methods inherited from class Object

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

Field Details

logger

protected final org.apache.commons.logging.Log logger

Constructor Details

AbstractJmsListenerContainerFactory

public AbstractJmsListenerContainerFactory()

Method Details

setConnectionFactory

public void setConnectionFactory(jakarta.jms.ConnectionFactory connectionFactory)

See Also:

• JmsAccessor.setConnectionFactory(ConnectionFactory)

setDestinationResolver

public void setDestinationResolver(DestinationResolver destinationResolver)

See Also:

• JmsDestinationAccessor.setDestinationResolver(DestinationResolver)

setMessageConverter

public void setMessageConverter(MessageConverter messageConverter)

See Also:

• AbstractMessageListenerContainer.setMessageConverter(MessageConverter)

setExceptionListener

public void setExceptionListener(jakarta.jms.ExceptionListener exceptionListener)

Since:

5.2.8

See Also:

• AbstractMessageListenerContainer.setExceptionListener(ExceptionListener)

setErrorHandler

public void setErrorHandler(ErrorHandler errorHandler)

See Also:

• AbstractMessageListenerContainer.setErrorHandler(ErrorHandler)

setSessionTransacted

public void setSessionTransacted(Boolean sessionTransacted)

See Also:

• JmsAccessor.setSessionTransacted(boolean)

setSessionAcknowledgeMode

public void setSessionAcknowledgeMode(Integer sessionAcknowledgeMode)

See Also:

• JmsAccessor.setSessionAcknowledgeMode(int)

setAcknowledgeAfterListener

public void setAcknowledgeAfterListener(Boolean acknowledgeAfterListener)

Since:

6.2.6

See Also:

• AbstractMessageListenerContainer.setAcknowledgeAfterListener(boolean)

setPubSubDomain

public void setPubSubDomain(Boolean pubSubDomain)

See Also:

• JmsDestinationAccessor.setPubSubDomain(boolean)

setReplyPubSubDomain

public void setReplyPubSubDomain(Boolean replyPubSubDomain)

See Also:

• AbstractMessageListenerContainer.setReplyPubSubDomain(boolean)

setReplyQosSettings

public void setReplyQosSettings(QosSettings replyQosSettings)

See Also:

• AbstractMessageListenerContainer.setReplyQosSettings(QosSettings)

setSubscriptionDurable

public void setSubscriptionDurable(Boolean subscriptionDurable)

See Also:

• AbstractMessageListenerContainer.setSubscriptionDurable(boolean)

setSubscriptionShared

public void setSubscriptionShared(Boolean subscriptionShared)

See Also:

• AbstractMessageListenerContainer.setSubscriptionShared(boolean)

setClientId

public void setClientId(String clientId)

See Also:

• AbstractJmsListeningContainer.setClientId(String)

setPhase

public void setPhase(int phase)

See Also:

• AbstractJmsListeningContainer.setPhase(int)

setAutoStartup

public void setAutoStartup(boolean autoStartup)

See Also:

• AbstractJmsListeningContainer.setAutoStartup(boolean)

setObservationRegistry

public void setObservationRegistry(io.micrometer.observation.ObservationRegistry observationRegistry)

Set the ObservationRegistry to be used for recording JMS message processing observations.

Defaults to no-op observations if the registry is not set.

Since:

6.1

See Also:

• AbstractMessageListenerContainer.setObservationRegistry(ObservationRegistry)

createListenerContainer

public C createListenerContainer(JmsListenerEndpoint endpoint)

Description copied from interface: JmsListenerContainerFactory

Create a MessageListenerContainer for the given JmsListenerEndpoint.

Specified by:

createListenerContainer in interface JmsListenerContainerFactory<C extends AbstractMessageListenerContainer>

Parameters:

endpoint - the endpoint to configure

Returns:

the created container

createContainerInstance

protected abstract C createContainerInstance()

Create an empty container instance.

initializeContainer

protected void initializeContainer(C instance)

Further initialize the specified container.

Subclasses can inherit from this method to apply extra configuration if necessary.