Class StompInboundChannelAdapter
java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.MessageProducerSupport
org.springframework.integration.stomp.inbound.StompInboundChannelAdapter
- All Implemented Interfaces:
org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanFactoryAware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.InitializingBean,org.springframework.beans.factory.SmartInitializingSingleton,org.springframework.context.ApplicationContextAware,org.springframework.context.ApplicationEventPublisherAware,org.springframework.context.Lifecycle,org.springframework.context.Phased,org.springframework.context.SmartLifecycle,org.springframework.integration.context.ExpressionCapable,org.springframework.integration.core.MessageProducer,org.springframework.integration.IntegrationPattern,org.springframework.integration.support.context.NamedComponent,org.springframework.integration.support.management.ManageableLifecycle,org.springframework.integration.support.management.ManageableSmartLifecycle,org.springframework.integration.support.management.TrackableComponent
@ManagedResource
@IntegrationManagedResource
public class StompInboundChannelAdapter
extends org.springframework.integration.endpoint.MessageProducerSupport
implements org.springframework.context.ApplicationEventPublisherAware
The
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.
- Since:
- 4.2
-
Field Summary
Fields inherited from class org.springframework.integration.endpoint.AbstractEndpoint
lifecycleCondition, lifecycleLock -
Constructor Summary
Constructors Constructor Description StompInboundChannelAdapter(StompSessionManager stompSessionManager, java.lang.String... destinations) -
Method Summary
Modifier and Type Method Description voidaddDestination(java.lang.String... destination)Add a destination (or destinations) to the subscribed list and subscribe it.protected voiddoStart()protected voiddoStop()java.lang.StringgetComponentType()java.lang.String[]getDestinations()voidremoveDestination(java.lang.String... destination)Remove a destination (or destinations) from the subscribed list and unsubscribe it.voidsetApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)voidsetHeaderMapper(org.springframework.integration.mapping.HeaderMapper<org.springframework.messaging.simp.stomp.StompHeaders> headerMapper)voidsetPayloadType(java.lang.Class<?> payloadType)Methods inherited from class org.springframework.integration.endpoint.MessageProducerSupport
afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, onInit, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisherMethods inherited from class org.springframework.integration.endpoint.AbstractEndpoint
destroy, doStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stopMethods inherited from class org.springframework.integration.context.IntegrationObjectSupport
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
-
Constructor Details
-
StompInboundChannelAdapter
public StompInboundChannelAdapter(StompSessionManager stompSessionManager, java.lang.String... destinations)
-
-
Method Details
-
setPayloadType
public void setPayloadType(java.lang.Class<?> payloadType) -
setHeaderMapper
public void setHeaderMapper(org.springframework.integration.mapping.HeaderMapper<org.springframework.messaging.simp.stomp.StompHeaders> headerMapper) -
setApplicationEventPublisher
public void setApplicationEventPublisher(org.springframework.context.ApplicationEventPublisher applicationEventPublisher)- Specified by:
setApplicationEventPublisherin interfaceorg.springframework.context.ApplicationEventPublisherAware
-
getDestinations
@ManagedAttribute public java.lang.String[] getDestinations() -
addDestination
@ManagedOperation public void addDestination(java.lang.String... destination)Add a destination (or destinations) to the subscribed list and subscribe it.- Parameters:
destination- The destinations.
-
removeDestination
@ManagedOperation public void removeDestination(java.lang.String... destination)Remove a destination (or destinations) from the subscribed list and unsubscribe it.- Parameters:
destination- The destinations.
-
getComponentType
public java.lang.String getComponentType()- Specified by:
getComponentTypein interfaceorg.springframework.integration.support.context.NamedComponent- Overrides:
getComponentTypein classorg.springframework.integration.context.IntegrationObjectSupport
-
doStart
protected void doStart()- Overrides:
doStartin classorg.springframework.integration.endpoint.MessageProducerSupport
-
doStop
protected void doStop()- Overrides:
doStopin classorg.springframework.integration.endpoint.MessageProducerSupport
-