public class StompMessageHandler extends AbstractMessageHandler implements ApplicationEventPublisherAware, ManageableLifecycle
AbstractMessageHandler
実装。IntegrationManagement.ManagementOverrides
EXPRESSION_PARSER, logger
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME
コンストラクターと説明 |
---|
StompMessageHandler(StompSessionManager stompSessionManager) |
修飾子と型 | メソッドと説明 |
---|---|
protected void | handleMessageInternal(Message<?> message) |
boolean | isRunning() |
protected void | onInit() サブクラスは、初期化ロジック用にこれを実装できます。 |
void | setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) |
void | setConnectTimeout(long connectTimeout) STOMP セッションの確立を待機するタイムアウトをミリ秒単位で指定します。 |
void | setDestination(StringSE destination) |
void | setDestinationExpression(Expression destinationExpression) |
void | setHeaderMapper(HeaderMapper<StompHeaders> headerMapper) |
void | setIntegrationEvaluationContext(EvaluationContext evaluationContext) |
void | start() |
void | stop() |
handleMessage, onComplete, onError, onNext, onSubscribe
buildSendTimer, destroy, getComponentType, getIntegrationPatternType, getManagedName, getManagedType, getMetricsCaptor, getOrder, getOverrides, isLoggingEnabled, registerMetricsCaptor, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, 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
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE
getThisAs
getBeanName, getComponentName
public StompMessageHandler(StompSessionManager stompSessionManager)
public void setDestination(StringSE destination)
public void setDestinationExpression(Expression destinationExpression)
public void setHeaderMapper(HeaderMapper<StompHeaders> headerMapper)
public void setConnectTimeout(long connectTimeout)
AbstractStompSessionManager.setRecoveryInterval(int)
より大きくなければなりません。connectTimeout
- 使用するタイムアウト。public void setIntegrationEvaluationContext(EvaluationContext evaluationContext)
public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
ApplicationEventPublisherAware
の setApplicationEventPublisher
protected void onInit()
IntegrationObjectSupport
IntegrationObjectSupport
の onInit
protected void handleMessageInternal(Message<?> message)
AbstractMessageHandler
の handleMessageInternal
public void start()
Lifecycle
の start
ManageableLifecycle
の start
public void stop()
Lifecycle
の stop
ManageableLifecycle
の stop
public boolean isRunning()
Lifecycle
の isRunning
ManageableLifecycle
の isRunning