Class PollableJmsChannel
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.channel.AbstractMessageChannel
org.springframework.integration.jms.AbstractJmsChannel
org.springframework.integration.jms.PollableJmsChannel
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.InitializingBean,org.springframework.context.ApplicationContextAware,org.springframework.integration.channel.ExecutorChannelInterceptorAware,org.springframework.integration.context.ExpressionCapable,org.springframework.integration.IntegrationPattern,org.springframework.integration.support.context.NamedComponent,org.springframework.integration.support.management.IntegrationManagement,org.springframework.integration.support.management.TrackableComponent,org.springframework.messaging.MessageChannel,org.springframework.messaging.PollableChannel,org.springframework.messaging.support.InterceptableChannel
public class PollableJmsChannel
extends AbstractJmsChannel
implements org.springframework.messaging.PollableChannel, org.springframework.integration.channel.ExecutorChannelInterceptorAware
- Since:
- 2.0
-
Nested Class Summary
Nested classes/interfaces inherited from class org.springframework.integration.channel.AbstractMessageChannel
org.springframework.integration.channel.AbstractMessageChannel.ChannelInterceptorListNested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement
org.springframework.integration.support.management.IntegrationManagement.ManagementOverrides -
Field Summary
Fields inherited from class org.springframework.integration.channel.AbstractMessageChannel
interceptors, metersFields inherited from class org.springframework.integration.context.IntegrationObjectSupport
EXPRESSION_PARSER, loggerFields inherited from interface org.springframework.integration.support.management.IntegrationManagement
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAMEFields inherited from interface org.springframework.messaging.MessageChannel
INDEFINITE_TIMEOUT -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidaddInterceptor(int index, org.springframework.messaging.support.ChannelInterceptor interceptor) voidaddInterceptor(org.springframework.messaging.support.ChannelInterceptor interceptor) booleanorg.springframework.messaging.Message<?>receive()org.springframework.messaging.Message<?>receive(long timeout) org.springframework.messaging.support.ChannelInterceptorremoveInterceptor(int index) booleanremoveInterceptor(org.springframework.messaging.support.ChannelInterceptor interceptor) voidsetInterceptors(List<org.springframework.messaging.support.ChannelInterceptor> interceptors) voidsetMessageSelector(String messageSelector) Methods inherited from class org.springframework.integration.jms.AbstractJmsChannel
doSendMethods inherited from class org.springframework.integration.channel.AbstractMessageChannel
destroy, getComponentType, getFullChannelName, getIChannelInterceptorList, getIntegrationPatternType, getInterceptors, getMetricsCaptor, getOverrides, isLoggingEnabled, onInit, registerMetricsCaptor, send, send, setDatatypes, setLoggingEnabled, setMessageConverter, setShouldTrackMethods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.springframework.integration.support.management.IntegrationManagement
getManagedName, getManagedType, getThisAs, registerObservationRegistry, setManagedName, setManagedTypeMethods inherited from interface org.springframework.messaging.support.InterceptableChannel
getInterceptorsMethods inherited from interface org.springframework.messaging.MessageChannel
send, sendMethods inherited from interface org.springframework.integration.support.context.NamedComponent
getBeanName, getComponentName
-
Constructor Details
-
PollableJmsChannel
public PollableJmsChannel(org.springframework.jms.core.JmsTemplate jmsTemplate)
-
-
Method Details
-
setMessageSelector
-
receive
@Nullable public org.springframework.messaging.Message<?> receive(long timeout) - Specified by:
receivein interfaceorg.springframework.messaging.PollableChannel
-
receive
@Nullable public org.springframework.messaging.Message<?> receive()- Specified by:
receivein interfaceorg.springframework.messaging.PollableChannel
-
setInterceptors
public void setInterceptors(List<org.springframework.messaging.support.ChannelInterceptor> interceptors) - Specified by:
setInterceptorsin interfaceorg.springframework.messaging.support.InterceptableChannel- Overrides:
setInterceptorsin classorg.springframework.integration.channel.AbstractMessageChannel
-
addInterceptor
public void addInterceptor(org.springframework.messaging.support.ChannelInterceptor interceptor) - Specified by:
addInterceptorin interfaceorg.springframework.messaging.support.InterceptableChannel- Overrides:
addInterceptorin classorg.springframework.integration.channel.AbstractMessageChannel
-
addInterceptor
public void addInterceptor(int index, org.springframework.messaging.support.ChannelInterceptor interceptor) - Specified by:
addInterceptorin interfaceorg.springframework.messaging.support.InterceptableChannel- Overrides:
addInterceptorin classorg.springframework.integration.channel.AbstractMessageChannel
-
removeInterceptor
public boolean removeInterceptor(org.springframework.messaging.support.ChannelInterceptor interceptor) - Specified by:
removeInterceptorin interfaceorg.springframework.messaging.support.InterceptableChannel- Overrides:
removeInterceptorin classorg.springframework.integration.channel.AbstractMessageChannel
-
removeInterceptor
@Nullable public org.springframework.messaging.support.ChannelInterceptor removeInterceptor(int index) - Specified by:
removeInterceptorin interfaceorg.springframework.messaging.support.InterceptableChannel- Overrides:
removeInterceptorin classorg.springframework.integration.channel.AbstractMessageChannel
-
hasExecutorInterceptors
public boolean hasExecutorInterceptors()- Specified by:
hasExecutorInterceptorsin interfaceorg.springframework.integration.channel.ExecutorChannelInterceptorAware
-