public class JmsMessageDrivenEndpoint extends MessageProducerSupport implements OrderlyShutdownCapable
lifecycleCondition, lifecycleLock
EXPRESSION_PARSER, logger
DEFAULT_PHASE
コンストラクターと説明 |
---|
JmsMessageDrivenEndpoint(AbstractMessageListenerContainer listenerContainer, ChannelPublishingJmsMessageListener listener) 外部で構成されたコンテナーを使用してインスタンスを作成します。 |
修飾子と型 | メソッドと説明 |
---|---|
int | afterShutdown() スケジューラー、エグゼキューターなどの通常のシャットダウンの後、シャットダウン遅延が経過した後、残りのアクティブなスケジューラー / エグゼキュータースレッドの強制シャットダウンの前に呼び出されます。オプションで、まだ処理中のアクティブなメッセージの数を返すことができます。 |
void | afterSingletonsInstantiated() |
int | beforeShutdown() シャットダウンが始まる前に呼び出されます。 |
void | destroy() |
protected void | doStart() デフォルトでは何もしません。 |
protected void | doStop() デフォルトでは何もしません。 |
StringSE | getComponentType() サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。 |
ChannelPublishingJmsMessageListener | getListener() |
protected void | onInit() サブクラスは、初期化ロジック用にこれを実装できます。 |
void | setApplicationContext(ApplicationContext applicationContext) |
void | setErrorChannel(MessageChannel errorChannel) |
void | setErrorChannelName(StringSE errorChannelName) エラーチャネル名を設定します。 |
void | setOutputChannel(MessageChannel outputChannel) 生成されたメッセージの送信先となる MessageChannel を指定します。 |
void | setOutputChannelName(StringSE outputChannelName) 出力チャネル名を設定します。提供されている場合、 outputChannel をオーバーライドします。 |
void | setSendTimeout(long sendTimeout) 送信操作に使用するデフォルトのタイムアウト値を構成します。 |
void | setSessionAcknowledgeMode(StringSE sessionAcknowledgeMode) リスナーコンテナーにセッション確認応答モードを設定します。 |
void | setShouldTrack(boolean shouldTrack) |
void | setShutdownContainerOnStop(boolean shutdownContainerOnStop) エンドポイントが停止したときにリスナーコンテナーがシャットダウンしないようにするには、false に設定します。 |
buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorMessageStrategy, subscribeToPublisher
doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE
getBeanName, getComponentName
public JmsMessageDrivenEndpoint(AbstractMessageListenerContainer listenerContainer, ChannelPublishingJmsMessageListener listener)
listenerContainer
- コンテナー。listener
- リスナー。public void setSessionAcknowledgeMode(StringSE sessionAcknowledgeMode)
DefaultMessageListenerContainer
を作成する場合は `transacted`。sessionAcknowledgeMode
- 確認モード。public void setOutputChannel(MessageChannel outputChannel)
MessageProducer
MessageChannel
を指定します。MessageProducer
の setOutputChannel
MessageProducerSupport
の setOutputChannel
outputChannel
- 出力チャネル。public void setOutputChannelName(StringSE outputChannelName)
MessageProducerSupport
outputChannel
をオーバーライドします。MessageProducer
の setOutputChannelName
MessageProducerSupport
の setOutputChannelName
outputChannelName
- チャンネル名。public void setErrorChannel(MessageChannel errorChannel)
MessageProducerSupport
の setErrorChannel
public void setErrorChannelName(StringSE errorChannelName)
MessageProducerSupport
MessageProducerSupport
の setErrorChannelName
errorChannelName
- エラーチャネル Bean 名。public void setSendTimeout(long sendTimeout)
MessageProducerSupport
MessageProducerSupport
の setSendTimeout
sendTimeout
- ミリ秒単位の送信タイムアウト GenericMessagingTemplate.setSendTimeout(long)
public void setShouldTrack(boolean shouldTrack)
TrackableComponent
の setShouldTrack
MessageProducerSupport
の setShouldTrack
public void setShutdownContainerOnStop(boolean shutdownContainerOnStop)
shutdownContainerOnStop
- シャットダウンしない場合は false。public ChannelPublishingJmsMessageListener getListener()
public void setApplicationContext(ApplicationContext applicationContext) throws BeansException
ApplicationContextAware
の setApplicationContext
IntegrationObjectSupport
の setApplicationContext
BeansException
public StringSE getComponentType()
IntegrationObjectSupport
NamedComponent
の getComponentType
IntegrationObjectSupport
の getComponentType
public void afterSingletonsInstantiated()
SmartInitializingSingleton
の afterSingletonsInstantiated
MessageProducerSupport
の afterSingletonsInstantiated
protected void onInit()
IntegrationObjectSupport
MessageProducerSupport
の onInit
protected void doStart()
MessageProducerSupport
MessageProducerSupport
の doStart
protected void doStop()
MessageProducerSupport
MessageProducerSupport
の doStop
public void destroy()
DisposableBean
の destroy
AbstractEndpoint
の destroy
public int beforeShutdown()
OrderlyShutdownCapable
OrderlyShutdownCapable
の beforeShutdown
public int afterShutdown()
OrderlyShutdownCapable
OrderlyShutdownCapable
の afterShutdown