public class SubscribableJmsChannel extends AbstractJmsChannel implements BroadcastCapableChannel, ManageableSmartLifecycle
AbstractJmsChannel
実装。また、JMS トピックに対して構成されたときに可能な pub-sub セマンティクスを表す BroadcastCapableChannel
を実装します。AbstractMessageChannel.ChannelInterceptorList
IntegrationManagement.ManagementOverrides
interceptors, meters
EXPRESSION_PARSER, logger
INDEFINITE_TIMEOUT
DEFAULT_PHASE
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
コンストラクターと説明 |
---|
SubscribableJmsChannel(AbstractMessageListenerContainer container, JmsTemplate jmsTemplate) |
修飾子と型 | メソッドと説明 |
---|---|
void | destroy() |
int | getPhase() |
boolean | isAutoStartup() |
boolean | isBroadcast() ブロードキャスト機能に関して、このチャネルの状態を返します。 |
boolean | isRunning() |
void | onInit() サブクラスは、初期化ロジック用にこれを実装できます。 |
void | setMaxSubscribers(int maxSubscribers) チャネルのディスパッチャーがサポートするサブスクライバの最大数を指定します。 |
void | start() |
void | stop() |
void | stop(RunnableSE callback) |
boolean | subscribe(MessageHandler handler) |
boolean | unsubscribe(MessageHandler handler) |
doSend
addInterceptor, addInterceptor, getComponentType, getFullChannelName, getIChannelInterceptorList, getIntegrationPatternType, getInterceptors, getMetricsCaptor, getOverrides, isLoggingEnabled, registerMetricsCaptor, removeInterceptor, removeInterceptor, send, send, setDatatypes, setInterceptors, setLoggingEnabled, setMessageConverter, setShouldTrack
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, toString
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE
send, send
getManagedName, getManagedType, getThisAs, setManagedName, setManagedType
getBeanName, getComponentName
public SubscribableJmsChannel(AbstractMessageListenerContainer container, JmsTemplate jmsTemplate)
public void setMaxSubscribers(int maxSubscribers)
maxSubscribers
- 許可されるサブスクライバーの最大数。public boolean subscribe(MessageHandler handler)
SubscribableChannel
の subscribe
public boolean unsubscribe(MessageHandler handler)
SubscribableChannel
の unsubscribe
public boolean isBroadcast()
BroadcastCapableChannel
BroadcastCapableChannel
の isBroadcast
public void onInit()
IntegrationObjectSupport
AbstractMessageChannel
の onInit
public boolean isAutoStartup()
SmartLifecycle
の isAutoStartup
public int getPhase()
Phased
の getPhase
SmartLifecycle
の getPhase
public boolean isRunning()
Lifecycle
の isRunning
ManageableLifecycle
の isRunning
public void start()
Lifecycle
の start
ManageableLifecycle
の start
public void stop()
Lifecycle
の stop
ManageableLifecycle
の stop
public void stop(RunnableSE callback)
SmartLifecycle
の stop
public void destroy()
DisposableBean
の destroy
IntegrationManagement
の destroy
AbstractMessageChannel
の destroy