public abstract class MessageProducerSupport extends AbstractEndpoint implements MessageProducer, TrackableComponent, SmartInitializingSingleton, IntegrationPattern
lifecycleCondition, lifecycleLock
EXPRESSION_PARSER, logger
DEFAULT_PHASE
修飾子 | コンストラクターと説明 |
---|---|
protected | MessageProducerSupport() |
修飾子と型 | メソッドと説明 |
---|---|
void | afterSingletonsInstantiated() |
protected ErrorMessage | buildErrorMessage(Message<?> message, ExceptionSE exception) 構成された ErrorMessageStrategy を使用して、例外とメッセージのエラーメッセージを作成します。 |
protected void | doStart() デフォルトでは何もしません。 |
protected void | doStop() デフォルトでは何もしません。 |
MessageChannel | getErrorChannel() エラーメッセージがルーティングされるエラーチャネル(提供されている場合)を返します。 |
protected AttributeAccessor | getErrorMessageAttributes(Message<?> message) errorMessageStrategy でエラーメッセージを作成するときに使用する AttributeAccessor を設定します。 |
IntegrationPatternType | getIntegrationPatternType() このコンポーネントが実装するパターン型を返します。 |
protected MessagingTemplate | getMessagingTemplate() |
MessageChannel | getOutputChannel() 出力チャネルを返します。 |
protected void | onInit() サブクラスは、初期化ロジック用にこれを実装できます。 |
protected boolean | sendErrorMessageIfNecessary(Message<?> message, ExceptionSE exception) 例外とメッセージに基づいてエラーメッセージを送信します。 |
protected void | sendMessage(Message<?> messageArg) |
void | setErrorChannel(MessageChannel errorChannel) |
void | setErrorChannelName(StringSE errorChannelName) エラーチャネル名を設定します。 |
void | setErrorMessageStrategy(ErrorMessageStrategy errorMessageStrategy) 例外が発生したときにエラーメッセージを作成するために使用する ErrorMessageStrategy を設定します。 |
void | setOutputChannel(MessageChannel outputChannel) 生成されたメッセージの送信先となる MessageChannel を指定します。 |
void | setOutputChannelName(StringSE outputChannelName) 出力チャネル名を設定します。提供されている場合、 outputChannel をオーバーライドします。 |
void | setSendTimeout(long sendTimeout) 送信操作に使用するデフォルトのタイムアウト値を構成します。 |
void | setShouldTrack(boolean shouldTrack) |
protected void | subscribeToPublisher(org.reactivestreams.Publisher<? extends Message<?>> publisher) |
destroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getComponentType, 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
getBeanName, getComponentName, getComponentType
public void setOutputChannel(MessageChannel outputChannel)
MessageProducer
MessageChannel
を指定します。MessageProducer
の setOutputChannel
outputChannel
- 出力チャネル。public void setOutputChannelName(StringSE outputChannelName)
outputChannel
をオーバーライドします。MessageProducer
の setOutputChannelName
outputChannelName
- チャンネル名。public MessageChannel getOutputChannel()
MessageProducer
MessageProducer
の getOutputChannel
public void setErrorChannel(MessageChannel errorChannel)
public void setErrorChannelName(StringSE errorChannelName)
errorChannelName
- エラーチャネル Bean 名。@Nullable public MessageChannel getErrorChannel()
public void setSendTimeout(long sendTimeout)
sendTimeout
- ミリ秒単位の送信タイムアウト GenericMessagingTemplate.setSendTimeout(long)
public void setShouldTrack(boolean shouldTrack)
TrackableComponent
の setShouldTrack
public final void setErrorMessageStrategy(ErrorMessageStrategy errorMessageStrategy)
ErrorMessageStrategy
を設定します。デフォルトは DefaultErrorMessageStrategy
です。errorMessageStrategy
- ErrorMessageStrategy
protected MessagingTemplate getMessagingTemplate()
public IntegrationPatternType getIntegrationPatternType()
IntegrationPattern
IntegrationPattern
の getIntegrationPatternType
IntegrationPatternType
public void afterSingletonsInstantiated()
SmartInitializingSingleton
の afterSingletonsInstantiated
protected void onInit()
IntegrationObjectSupport
AbstractEndpoint
の onInit
protected void doStart()
AbstractEndpoint
の doStart
protected void doStop()
AbstractEndpoint
の doStop
protected void sendMessage(Message<?> messageArg)
protected void subscribeToPublisher(org.reactivestreams.Publisher<? extends Message<?>> publisher)
protected final boolean sendErrorMessageIfNecessary(@Nullable Message<?> message, ExceptionSE exception)
message
- メッセージ。exception
- 例外。protected final ErrorMessage buildErrorMessage(@Nullable Message<?> message, ExceptionSE exception)
ErrorMessageStrategy
を使用して、例外とメッセージのエラーメッセージを作成します。message
- メッセージ。exception
- 例外。protected AttributeAccessor getErrorMessageAttributes(@Nullable Message<?> message)
errorMessageStrategy
でエラーメッセージを作成するときに使用する AttributeAccessor
を設定します。message
- メッセージ。