@ManagedResource
@IntegrationManagedResource
public class StompInboundChannelAdapter
extends org.springframework.integration.endpoint.MessageProducerSupport
implements org.springframework.context.ApplicationEventPublisherAware
MessageProducerSupport for STOMP protocol to handle STOMP frames from
provided destination and send messages to the outputChannel.
Destinations can be added and removed at runtime.
The StompReceiptEvent is emitted for each Subscribe STOMP frame
if provided StompSessionManager supports autoReceiptEnabled.
lifecycleCondition, lifecycleLock| Constructor and Description |
|---|
StompInboundChannelAdapter(StompSessionManager stompSessionManager,
java.lang.String... destinations) |
| Modifier and Type | Method and Description |
|---|---|
void |
addDestination(java.lang.String... destination)
Add a destination (or destinations) to the subscribed list and subscribe it.
|
protected void |
doStart() |
protected void |
doStop() |
java.lang.String |
getComponentType() |
java.lang.String[] |
getDestinations() |
void |
removeDestination(java.lang.String... destination)
Remove a destination (or destinations) from the subscribed list and unsubscribe it.
|
void |
setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher) |
void |
setErrorChannel(org.springframework.messaging.MessageChannel errorChannel) |
void |
setHeaderMapper(org.springframework.integration.mapping.HeaderMapper<org.springframework.messaging.simp.stomp.StompHeaders> headerMapper) |
void |
setPayloadType(java.lang.Class<?> payloadType) |
afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getMessagingTemplate, getOutputChannel, onInit, sendErrorMessageIfNecessary, sendMessage, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrackdestroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, setTaskScheduler, start, stop, stopafterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, toStringpublic StompInboundChannelAdapter(StompSessionManager stompSessionManager, java.lang.String... destinations)
public void setPayloadType(java.lang.Class<?> payloadType)
public void setErrorChannel(org.springframework.messaging.MessageChannel errorChannel)
setErrorChannel in class org.springframework.integration.endpoint.MessageProducerSupportpublic void setHeaderMapper(org.springframework.integration.mapping.HeaderMapper<org.springframework.messaging.simp.stomp.StompHeaders> headerMapper)
public void setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)
setApplicationEventPublisher in interface org.springframework.context.ApplicationEventPublisherAware@ManagedAttribute public java.lang.String[] getDestinations()
@ManagedOperation public void addDestination(java.lang.String... destination)
destination - The destinations.@ManagedOperation public void removeDestination(java.lang.String... destination)
destination - The destinations.public java.lang.String getComponentType()
getComponentType in interface org.springframework.integration.support.context.NamedComponentgetComponentType in class org.springframework.integration.context.IntegrationObjectSupportprotected void doStart()
doStart in class org.springframework.integration.endpoint.MessageProducerSupportprotected void doStop()
doStop in class org.springframework.integration.endpoint.MessageProducerSupport