StompMessageHandler (Spring Integration 4.2.9.RELEASE API)

java.lang.Object
- org.springframework.integration.context.IntegrationObjectSupport
- - org.springframework.integration.handler.AbstractMessageHandler
  - - org.springframework.integration.stomp.outbound.StompMessageHandler

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, InitializingBean, ApplicationContextAware, ApplicationEventPublisherAware, Lifecycle, Ordered, Orderable, NamedComponent, ConfigurableMetricsAware<AbstractMessageHandlerMetrics>, IntegrationManagement, IntegrationStatsManagement, MessageHandlerMetrics, TrackableComponent, MessageHandler
```
public class StompMessageHandler
extends AbstractMessageHandler
implements ApplicationEventPublisherAware, Lifecycle
```
The AbstractMessageHandler implementation to send messages to STOMP destinations.

Since:

4.2

Author:

Artem Bilan

Field Summary
- Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport
  logger
- Fields inherited from interface org.springframework.core.Ordered
  HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors
Constructor and Description

StompMessageHandler(StompSessionManager stompSessionManager)

Constructors
Constructor and Description
`StompMessageHandler(StompSessionManager stompSessionManager)`

Method Summary

All Methods Instance Methods Concrete Methods
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()`

Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler
configureMetrics, getActiveCount, getActiveCountLong, getComponentType, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport
afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setTaskScheduler, toString

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.springframework.integration.support.context.NamedComponent
getComponentName

- Constructor Detail
  - StompMessageHandler
```
public StompMessageHandler(StompSessionManager stompSessionManager)
```
- Method Detail
  - setDestination
```
public void setDestination(String destination)
```
  - setDestinationExpression
```
public void setDestinationExpression(Expression destinationExpression)
```
  - setHeaderMapper
```
public void setHeaderMapper(HeaderMapper<StompHeaders> headerMapper)
```
  - setConnectTimeout
```
public void setConnectTimeout(long connectTimeout)
```
    Specify the the timeout in milliseconds to wait for the STOMP session establishment. Must be greater than AbstractStompSessionManager.setRecoveryInterval(int).
    
    Parameters:
    
    connectTimeout - the timeout to use.
    
    Since:
    
    4.2.2
  - setIntegrationEvaluationContext
```
public void setIntegrationEvaluationContext(EvaluationContext evaluationContext)
```
  - setApplicationEventPublisher
```
public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
```
    Specified by:
    
    setApplicationEventPublisher in interface ApplicationEventPublisherAware
  - onInit
```
protected void onInit()
               throws Exception
```
    Description copied from class: IntegrationObjectSupport
    
    Subclasses may implement this for initialization logic.
    
    Overrides:
    
    onInit in class AbstractMessageHandler
    
    Throws:
    
    Exception - Any exception.
  - handleMessageInternal
```
protected void handleMessageInternal(Message<?> message)
                              throws Exception
```
    Specified by:
    
    handleMessageInternal in class AbstractMessageHandler
    
    Throws:
    
    Exception
  - start
```
public void start()
```
    Specified by:
    
    start in interface Lifecycle
  - stop
```
public void stop()
```
    Specified by:
    
    stop in interface Lifecycle
  - isRunning
```
public boolean isRunning()
```
    Specified by:
    
    isRunning in interface Lifecycle

Class StompMessageHandler

Field Summary

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

Fields inherited from interface org.springframework.core.Ordered

Constructor Summary

Method Summary

Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

Methods inherited from class java.lang.Object

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

Constructor Detail

StompMessageHandler

Method Detail

setDestination

setDestinationExpression

setHeaderMapper

setConnectTimeout

setIntegrationEvaluationContext

setApplicationEventPublisher

onInit

handleMessageInternal

start

stop

isRunning