public abstract class MessageProducerSupport extends AbstractEndpoint implements MessageProducer, TrackableComponent, SmartInitializingSingleton, IntegrationPattern
lifecycleCondition, lifecycleLockEXPRESSION_PARSER, loggerDEFAULT_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, stopafterPropertiesSet, 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, toStringcloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSEgetBeanName, getComponentName, getComponentTypepublic void setOutputChannel(MessageChannel outputChannel)
MessageProducerMessageChannel を指定します。MessageProducer の setOutputChannel outputChannel - 出力チャネル。public void setOutputChannelName(StringSE outputChannelName)
outputChannel をオーバーライドします。MessageProducer の setOutputChannelName outputChannelName - チャンネル名。public MessageChannel getOutputChannel()
MessageProducerMessageProducer の 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 - ErrorMessageStrategyprotected MessagingTemplate getMessagingTemplate()
public IntegrationPatternType getIntegrationPatternType()
IntegrationPatternIntegrationPattern の getIntegrationPatternType IntegrationPatternTypepublic void afterSingletonsInstantiated()
SmartInitializingSingleton の afterSingletonsInstantiated protected void onInit()
IntegrationObjectSupportAbstractEndpoint の 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 - メッセージ。