@IntegrationManagedResource public abstract class AbstractMessageSource<T> extends AbstractExpressionEvaluator implements MessageSource<T>, MessageSourceMetrics, NamedComponent, org.springframework.beans.factory.BeanNameAware
IntegrationManagement.ManagementOverridesEXPRESSION_PARSER, loggerMETER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME| Constructor and Description |
|---|
AbstractMessageSource() |
| Modifier and Type | Method and Description |
|---|---|
protected org.springframework.messaging.Message<T> |
buildMessage(java.lang.Object result) |
protected abstract java.lang.Object |
doReceive()
Subclasses must implement this method.
|
java.lang.String |
getComponentName() |
java.lang.String |
getManagedName() |
java.lang.String |
getManagedType() |
int |
getMessageCount() |
long |
getMessageCountLong() |
IntegrationManagement.ManagementOverrides |
getOverrides()
Return the overrides.
|
boolean |
isCountsEnabled() |
boolean |
isLoggingEnabled() |
org.springframework.messaging.Message<T> |
receive()
Retrieve the next available message from this source.
|
void |
registerMetricsCaptor(MetricsCaptor metricsCaptor)
Inject a
MetricsCaptor |
void |
reset() |
void |
setBeanName(java.lang.String name) |
void |
setCountsEnabled(boolean countsEnabled) |
void |
setHeaderExpressions(java.util.Map<java.lang.String,org.springframework.expression.Expression> headerExpressions) |
void |
setLoggingEnabled(boolean loggingEnabled) |
void |
setManagedName(java.lang.String managedName) |
void |
setManagedType(java.lang.String managedType) |
afterPropertiesSet, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, evaluateExpression, getBeanFactory, getEvaluationContext, getEvaluationContext, getMessageBuilderFactory, onInit, setBeanFactory, setConversionServiceclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitsetCountergetComponentTypepublic void setHeaderExpressions(java.util.Map<java.lang.String,org.springframework.expression.Expression> headerExpressions)
public void registerMetricsCaptor(MetricsCaptor metricsCaptor)
IntegrationManagementMetricsCaptorregisterMetricsCaptor in interface IntegrationManagementmetricsCaptor - the captor.public void setBeanName(java.lang.String name)
setBeanName in interface org.springframework.beans.factory.BeanNameAwarepublic void setManagedType(java.lang.String managedType)
setManagedType in interface MessageSourceMetricspublic java.lang.String getManagedType()
getManagedType in interface MessageSourceMetricspublic void setManagedName(java.lang.String managedName)
setManagedName in interface MessageSourceMetricspublic java.lang.String getManagedName()
getManagedName in interface MessageSourceMetricspublic java.lang.String getComponentName()
getComponentName in interface NamedComponentpublic boolean isCountsEnabled()
isCountsEnabled in interface IntegrationManagementpublic void setCountsEnabled(boolean countsEnabled)
setCountsEnabled in interface IntegrationManagementpublic boolean isLoggingEnabled()
isLoggingEnabled in interface IntegrationManagementpublic void setLoggingEnabled(boolean loggingEnabled)
setLoggingEnabled in interface IntegrationManagementpublic void reset()
reset in interface IntegrationManagementpublic int getMessageCount()
getMessageCount in interface MessageSourceMetricspublic long getMessageCountLong()
getMessageCountLong in interface MessageSourceMetricspublic IntegrationManagement.ManagementOverrides getOverrides()
IntegrationManagementgetOverrides in interface IntegrationManagementpublic final org.springframework.messaging.Message<T> receive()
MessageSourcenull if no message is available.receive in interface MessageSource<T>protected org.springframework.messaging.Message<T> buildMessage(java.lang.Object result)
protected abstract java.lang.Object doReceive()
payload of
type T, but the returned value may also be a Message instance whose payload is of type T;
also can be AbstractIntegrationMessageBuilder which is used for additional headers population.