public class SubscribableJmsChannel extends AbstractJmsChannel implements org.springframework.integration.channel.BroadcastCapableChannel, org.springframework.integration.support.management.ManageableSmartLifecycle
AbstractJmsChannel implementation for message-driven subscriptions.
Also implements a BroadcastCapableChannel to represent possible pub-sub semantics
when configured against JMS topic.interceptors, meters| Constructor and Description |
|---|
SubscribableJmsChannel(org.springframework.jms.listener.AbstractMessageListenerContainer container,
org.springframework.jms.core.JmsTemplate jmsTemplate) |
| Modifier and Type | Method and Description |
|---|---|
void |
destroy() |
int |
getPhase() |
boolean |
isAutoStartup() |
boolean |
isBroadcast() |
boolean |
isRunning() |
void |
onInit() |
void |
setMaxSubscribers(int maxSubscribers)
Specify the maximum number of subscribers supported by the
channel's dispatcher.
|
void |
start() |
void |
stop() |
void |
stop(java.lang.Runnable callback) |
boolean |
subscribe(org.springframework.messaging.MessageHandler handler) |
boolean |
unsubscribe(org.springframework.messaging.MessageHandler handler) |
doSendaddInterceptor, addInterceptor, getComponentType, getFullChannelName, getIChannelInterceptorList, getIntegrationPatternType, getInterceptors, getMetricsCaptor, getOverrides, isLoggingEnabled, registerMetricsCaptor, removeInterceptor, removeInterceptor, send, send, setDatatypes, setInterceptors, setLoggingEnabled, setMessageConverter, setShouldTrackafterPropertiesSet, 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, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitpublic SubscribableJmsChannel(org.springframework.jms.listener.AbstractMessageListenerContainer container,
org.springframework.jms.core.JmsTemplate jmsTemplate)
public void setMaxSubscribers(int maxSubscribers)
maxSubscribers - The maximum number of subscribers allowed.public boolean subscribe(org.springframework.messaging.MessageHandler handler)
subscribe in interface org.springframework.messaging.SubscribableChannelpublic boolean unsubscribe(org.springframework.messaging.MessageHandler handler)
unsubscribe in interface org.springframework.messaging.SubscribableChannelpublic boolean isBroadcast()
isBroadcast in interface org.springframework.integration.channel.BroadcastCapableChannelpublic void onInit()
onInit in class org.springframework.integration.channel.AbstractMessageChannelpublic boolean isAutoStartup()
isAutoStartup in interface org.springframework.context.SmartLifecyclepublic int getPhase()
getPhase in interface org.springframework.context.PhasedgetPhase in interface org.springframework.context.SmartLifecyclepublic boolean isRunning()
isRunning in interface org.springframework.context.LifecycleisRunning in interface org.springframework.integration.support.management.ManageableLifecyclepublic void start()
start in interface org.springframework.context.Lifecyclestart in interface org.springframework.integration.support.management.ManageableLifecyclepublic void stop()
stop in interface org.springframework.context.Lifecyclestop in interface org.springframework.integration.support.management.ManageableLifecyclepublic void stop(java.lang.Runnable callback)
stop in interface org.springframework.context.SmartLifecyclepublic void destroy()
destroy in interface org.springframework.beans.factory.DisposableBeandestroy in interface org.springframework.integration.support.management.IntegrationManagementdestroy in class org.springframework.integration.channel.AbstractMessageChannel