diff --git a/spring-jms/src/main/java/org/springframework/jms/listener/AbstractMessageListenerContainer.java b/spring-jms/src/main/java/org/springframework/jms/listener/AbstractMessageListenerContainer.java index 2f857911b20..58c0c13380e 100644 --- a/spring-jms/src/main/java/org/springframework/jms/listener/AbstractMessageListenerContainer.java +++ b/spring-jms/src/main/java/org/springframework/jms/listener/AbstractMessageListenerContainer.java @@ -131,8 +131,8 @@ import org.springframework.util.ReflectionUtils; * @see SimpleMessageListenerContainer * @see org.springframework.jms.listener.endpoint.JmsMessageEndpointManager */ -public abstract class AbstractMessageListenerContainer - extends AbstractJmsListeningContainer implements MessageListenerContainer { +public abstract class AbstractMessageListenerContainer extends AbstractJmsListeningContainer + implements MessageListenerContainer { private static final Method createSharedConsumerMethod = ClassUtils.getMethodIfAvailable( Session.class, "createSharedConsumer", Topic.class, String.class, String.class); @@ -354,6 +354,7 @@ public abstract class AbstractMessageListenerContainer *

Only makes sense when listening to a topic (pub-sub domain), * therefore this method switches the "pubSubDomain" flag as well. *

Requires a JMS 2.0 compatible message broker. + * @since 4.1 * @see #setSubscriptionName * @see #setSubscriptionDurable * @see #setPubSubDomain @@ -367,6 +368,7 @@ public abstract class AbstractMessageListenerContainer /** * Return whether to make the subscription shared. + * @since 4.1 */ public boolean isSubscriptionShared() { return this.subscriptionShared; @@ -380,6 +382,7 @@ public abstract class AbstractMessageListenerContainer *

Note: Only 1 concurrent consumer (which is the default of this * message listener container) is allowed for each subscription, * except for a shared subscription (which requires JMS 2.0). + * @since 4.1 * @see #setPubSubDomain * @see #setSubscriptionDurable * @see #setSubscriptionShared @@ -390,6 +393,10 @@ public abstract class AbstractMessageListenerContainer this.subscriptionName = subscriptionName; } + /** + * Return the name of a subscription to create, if any. + * @since 4.1 + */ public String getSubscriptionName() { return this.subscriptionName; } @@ -423,6 +430,7 @@ public abstract class AbstractMessageListenerContainer /** * Set whether to inhibit the delivery of messages published by its own connection. * Default is "false". + * @since 4.1 * @see javax.jms.Session#createConsumer(javax.jms.Destination, String, boolean) */ public void setPubSubNoLocal(boolean pubSubNoLocal) { @@ -431,6 +439,7 @@ public abstract class AbstractMessageListenerContainer /** * Return whether to inhibit the delivery of messages published by its own connection. + * @since 4.1 */ public boolean isPubSubNoLocal() { return this.pubSubNoLocal; @@ -438,6 +447,7 @@ public abstract class AbstractMessageListenerContainer /** * Set the {@link MessageConverter} strategy for converting JMS Messages. + * @since 4.1 */ public void setMessageConverter(MessageConverter messageConverter) { this.messageConverter = messageConverter; @@ -477,6 +487,7 @@ public abstract class AbstractMessageListenerContainer /** * Return the ErrorHandler to be invoked in case of any uncaught exceptions thrown * while processing a Message. + * @since 4.1 */ public ErrorHandler getErrorHandler() { return this.errorHandler;