T
- ペイロード型。@IntegrationManagedResource public abstract class AbstractMessageSource<T> extends AbstractExpressionEvaluator implements MessageSource<T>, IntegrationInboundManagement, NamedComponent, BeanNameAware
IntegrationManagement.ManagementOverrides
EXPRESSION_PARSER, logger
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
コンストラクターと説明 |
---|
AbstractMessageSource() |
修飾子と型 | メソッドと説明 |
---|---|
protected Message<T> | buildMessage(ObjectSE result) |
void | destroy() |
protected abstract ObjectSE | doReceive() サブクラスはこのメソッドを実装する必要があります。 |
StringSE | getBeanName() |
StringSE | getComponentName() |
StringSE | getManagedName() |
StringSE | getManagedType() |
IntegrationManagement.ManagementOverrides | getOverrides() オーバーライドを返します。 |
boolean | isLoggingEnabled() ロギングが有効かどうかを返します。 |
Message<T> | receive() このソースから次に使用可能なメッセージを取得します。 |
void | registerMetricsCaptor(MetricsCaptor metricsCaptorToSet) MetricsCaptor を注入する |
void | setBeanName(StringSE name) |
void | setHeaderExpressions(MapSE<StringSE, Expression> headerExpressions) |
void | setLoggingEnabled(boolean loggingEnabled) ロギングを有効にするかどうか。 |
void | setManagedName(StringSE managedName) |
void | setManagedType(StringSE managedType) |
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, onInit, setBeanFactory, setConversionService
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
getIntegrationPatternType
getThisAs
getComponentType
public void setHeaderExpressions(@Nullable MapSE<StringSE,Expression> headerExpressions)
public void registerMetricsCaptor(MetricsCaptor metricsCaptorToSet)
IntegrationManagement
MetricsCaptor
を注入する IntegrationManagement
の registerMetricsCaptor
metricsCaptorToSet
- キャプター。public void setBeanName(StringSE name)
BeanNameAware
の setBeanName
public StringSE getBeanName()
NamedComponent
の getBeanName
public void setManagedType(StringSE managedType)
IntegrationManagement
の setManagedType
public StringSE getManagedType()
IntegrationManagement
の getManagedType
public void setManagedName(StringSE managedName)
IntegrationManagement
の setManagedName
public StringSE getManagedName()
IntegrationManagement
の getManagedName
public StringSE getComponentName()
NamedComponent
の getComponentName
public boolean isLoggingEnabled()
IntegrationManagement
IntegrationManagement
の isLoggingEnabled
public void setLoggingEnabled(boolean loggingEnabled)
IntegrationManagement
IntegrationManagement
の setLoggingEnabled
loggingEnabled
- 無効にする dalse。public IntegrationManagement.ManagementOverrides getOverrides()
IntegrationManagement
IntegrationManagement
の getOverrides
public final Message<T> receive()
MessageSource
null
を返します。MessageSource<T>
の receive
@Nullable protected abstract ObjectSE doReceive()
payload
ですが、戻り値はペイロードが T 型の Message
インスタンスでもかまいません。追加のヘッダーの作成に使用される AbstractIntegrationMessageBuilder
にすることもできます。public void destroy()
DisposableBean
の destroy
IntegrationManagement
の destroy