@IntegrationManagedResource public abstract class AbstractMessageHandler extends IntegrationObjectSupport implements MessageHandler, MessageHandlerMetrics, ConfigurableMetricsAware<AbstractMessageHandlerMetrics>, TrackableComponent, Orderable, reactor.core.CoreSubscriber<Message<?>>
MessagingException
s.IntegrationManagement.ManagementOverrides
EXPRESSION_PARSER, logger
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
Constructor and Description |
---|
AbstractMessageHandler() |
Modifier and Type | Method and Description |
---|---|
void |
configureMetrics(AbstractMessageHandlerMetrics metrics) |
void |
destroy() |
int |
getActiveCount() |
long |
getActiveCountLong() |
String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
Statistics |
getDuration() |
int |
getErrorCount() |
long |
getErrorCountLong() |
int |
getHandleCount() |
long |
getHandleCountLong() |
String |
getManagedName() |
String |
getManagedType() |
double |
getMaxDuration() |
double |
getMeanDuration() |
protected MetricsCaptor |
getMetricsCaptor() |
double |
getMinDuration() |
int |
getOrder() |
IntegrationManagement.ManagementOverrides |
getOverrides()
Return the overrides.
|
double |
getStandardDeviationDuration() |
void |
handleMessage(Message<?> messageArg) |
protected abstract void |
handleMessageInternal(Message<?> message) |
boolean |
isCountsEnabled() |
boolean |
isLoggingEnabled() |
boolean |
isStatsEnabled() |
void |
onComplete() |
void |
onError(Throwable throwable) |
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
void |
onNext(Message<?> message) |
void |
onSubscribe(org.reactivestreams.Subscription subscription) |
void |
registerMetricsCaptor(MetricsCaptor metricsCaptorToRegister)
Inject a
MetricsCaptor |
void |
reset() |
void |
setCountsEnabled(boolean countsEnabled) |
void |
setLoggingEnabled(boolean loggingEnabled) |
void |
setManagedName(String managedName) |
void |
setManagedType(String managedType) |
void |
setOrder(int order)
Set the order for this component.
|
void |
setShouldTrack(boolean shouldTrack) |
void |
setStatsEnabled(boolean statsEnabled) |
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
errorCount, handleCount
getBeanName, getComponentName
public boolean isLoggingEnabled()
isLoggingEnabled
in interface IntegrationManagement
public void setLoggingEnabled(boolean loggingEnabled)
setLoggingEnabled
in interface IntegrationManagement
public void registerMetricsCaptor(MetricsCaptor metricsCaptorToRegister)
IntegrationManagement
MetricsCaptor
registerMetricsCaptor
in interface IntegrationManagement
metricsCaptorToRegister
- the captor.@Nullable protected MetricsCaptor getMetricsCaptor()
public void setOrder(int order)
Orderable
public String getComponentType()
IntegrationObjectSupport
getComponentType
in interface NamedComponent
getComponentType
in class IntegrationObjectSupport
public void setShouldTrack(boolean shouldTrack)
setShouldTrack
in interface TrackableComponent
public void configureMetrics(AbstractMessageHandlerMetrics metrics)
configureMetrics
in interface ConfigurableMetricsAware<AbstractMessageHandlerMetrics>
public IntegrationManagement.ManagementOverrides getOverrides()
IntegrationManagement
getOverrides
in interface IntegrationManagement
protected void onInit()
IntegrationObjectSupport
onInit
in class IntegrationObjectSupport
public void handleMessage(Message<?> messageArg)
handleMessage
in interface MessageHandler
public void onSubscribe(org.reactivestreams.Subscription subscription)
public void onNext(Message<?> message)
onNext
in interface org.reactivestreams.Subscriber<Message<?>>
public void onError(Throwable throwable)
onError
in interface org.reactivestreams.Subscriber<Message<?>>
public void onComplete()
onComplete
in interface org.reactivestreams.Subscriber<Message<?>>
protected abstract void handleMessageInternal(Message<?> message)
public void reset()
reset
in interface IntegrationManagement
public long getHandleCountLong()
getHandleCountLong
in interface MessageHandlerMetrics
public int getHandleCount()
getHandleCount
in interface MessageHandlerMetrics
public int getErrorCount()
getErrorCount
in interface MessageHandlerMetrics
public long getErrorCountLong()
getErrorCountLong
in interface MessageHandlerMetrics
public double getMeanDuration()
getMeanDuration
in interface MessageHandlerMetrics
public double getMinDuration()
getMinDuration
in interface MessageHandlerMetrics
public double getMaxDuration()
getMaxDuration
in interface MessageHandlerMetrics
public double getStandardDeviationDuration()
getStandardDeviationDuration
in interface MessageHandlerMetrics
public int getActiveCount()
getActiveCount
in interface MessageHandlerMetrics
public long getActiveCountLong()
getActiveCountLong
in interface MessageHandlerMetrics
public Statistics getDuration()
getDuration
in interface MessageHandlerMetrics
public void setStatsEnabled(boolean statsEnabled)
setStatsEnabled
in interface IntegrationStatsManagement
public boolean isStatsEnabled()
isStatsEnabled
in interface IntegrationStatsManagement
public void setCountsEnabled(boolean countsEnabled)
setCountsEnabled
in interface IntegrationManagement
public boolean isCountsEnabled()
isCountsEnabled
in interface IntegrationManagement
public void setManagedName(String managedName)
setManagedName
in interface MessageHandlerMetrics
public String getManagedName()
getManagedName
in interface MessageHandlerMetrics
public void setManagedType(String managedType)
setManagedType
in interface MessageHandlerMetrics
public String getManagedType()
getManagedType
in interface MessageHandlerMetrics
public void destroy()
destroy
in interface DisposableBean
destroy
in interface IntegrationManagement