public class MethodInvokingMessageHandler extends AbstractMessageHandler implements org.springframework.context.Lifecycle
MessageHandler
that invokes the specified method on the provided object.IntegrationManagement.ManagementOverrides
EXPRESSION_PARSER, logger
Constructor and Description |
---|
MethodInvokingMessageHandler(java.lang.Object object,
java.lang.reflect.Method method) |
MethodInvokingMessageHandler(java.lang.Object object,
java.lang.String methodName) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getComponentType()
Subclasses may implement this method to provide component type information.
|
protected void |
handleMessageInternal(org.springframework.messaging.Message<?> message) |
boolean |
isRunning() |
void |
setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory) |
void |
setComponentType(java.lang.String componentType) |
void |
start() |
void |
stop() |
configureMetrics, getActiveCount, getActiveCountLong, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onComplete, onError, onInit, onNext, onSubscribe, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getComponentName
public MethodInvokingMessageHandler(java.lang.Object object, java.lang.reflect.Method method)
public MethodInvokingMessageHandler(java.lang.Object object, java.lang.String methodName)
public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
setBeanFactory
in interface org.springframework.beans.factory.BeanFactoryAware
setBeanFactory
in class IntegrationObjectSupport
public void setComponentType(java.lang.String componentType)
public java.lang.String getComponentType()
IntegrationObjectSupport
getComponentType
in interface NamedComponent
getComponentType
in class AbstractMessageHandler
public void start()
start
in interface org.springframework.context.Lifecycle
public void stop()
stop
in interface org.springframework.context.Lifecycle
public boolean isRunning()
isRunning
in interface org.springframework.context.Lifecycle
protected void handleMessageInternal(org.springframework.messaging.Message<?> message) throws java.lang.Exception
handleMessageInternal
in class AbstractMessageHandler
java.lang.Exception