public class StompMessageHandler extends AbstractMessageHandler implements ApplicationEventPublisherAware, Lifecycle
AbstractMessageHandler
implementation to send messages to STOMP destinations.IntegrationManagement.ManagementOverrides
EXPRESSION_PARSER, logger
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
Constructor and Description |
---|
StompMessageHandler(StompSessionManager stompSessionManager) |
Modifier and Type | Method and Description |
---|---|
protected void |
handleMessageInternal(Message<?> message) |
boolean |
isRunning() |
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
void |
setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) |
void |
setConnectTimeout(long connectTimeout)
Specify the the timeout in milliseconds to wait for the STOMP session establishment.
|
void |
setDestination(String destination) |
void |
setDestinationExpression(Expression destinationExpression) |
void |
setHeaderMapper(HeaderMapper<StompHeaders> headerMapper) |
void |
setIntegrationEvaluationContext(EvaluationContext evaluationContext) |
void |
start() |
void |
stop() |
handleMessage, onComplete, onError, onNext, onSubscribe
buildSendTimer, configureMetrics, destroy, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getHandlerMetrics, getIntegrationPatternType, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMetricsCaptor, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, isCountsEnabled, isLoggingEnabled, isStatsEnabled, registerMetricsCaptor, reset, sendTimer, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled, shouldTrack
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 StompMessageHandler(StompSessionManager stompSessionManager)
public void setDestination(String destination)
public void setDestinationExpression(Expression destinationExpression)
public void setHeaderMapper(HeaderMapper<StompHeaders> headerMapper)
public void setConnectTimeout(long connectTimeout)
AbstractStompSessionManager.setRecoveryInterval(int)
.connectTimeout
- the timeout to use.public void setIntegrationEvaluationContext(EvaluationContext evaluationContext)
public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
setApplicationEventPublisher
in interface ApplicationEventPublisherAware
protected void onInit()
IntegrationObjectSupport
onInit
in class MessageHandlerSupport
protected void handleMessageInternal(Message<?> message)
handleMessageInternal
in class AbstractMessageHandler