public class WebSocketInboundChannelAdapter extends MessageProducerSupport implements WebSocketListener, ApplicationEventPublisherAware
lifecycleCondition, lifecycleLockEXPRESSION_PARSER, loggerDEFAULT_PHASE| コンストラクターと説明 |
|---|
WebSocketInboundChannelAdapter(IntegrationWebSocketContainer webSocketContainer) |
WebSocketInboundChannelAdapter(IntegrationWebSocketContainer webSocketContainer, SubProtocolHandlerRegistry protocolHandlerRegistry) |
| 修飾子と型 | メソッドと説明 |
|---|---|
void | afterSessionEnded(WebSocketSession session, CloseStatus closeStatus)WebSocketSession が終了した後に呼び出されます。 |
void | afterSessionStarted(WebSocketSession session)WebSocketSession が開始した後に呼び出されます。 |
protected void | doStart() デフォルトでは何もしません。 |
protected void | doStop() デフォルトでは何もしません。 |
StringSE | getComponentType() サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。 |
ListSE<StringSE> | getSubProtocols() |
protected void | onInit() サブクラスは、初期化ロジック用にこれを実装できます。 |
void | onMessage(WebSocketSession session, WebSocketMessage<?> webSocketMessage) 受け取った WebSocketMessage を処理します。 |
void | setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) |
void | setMergeWithDefaultConverters(boolean mergeWithDefaultConverters) カスタムコンバーターの後にデフォルトコンバーターを使用できるかどうかを決定するフラグ。 |
void | setMessageConverters(ListSE<MessageConverter> messageConverters) 使用するメッセージコンバーターを設定します。 |
void | setPayloadType(ClassSE<?> payloadType)WebSocket メッセージ本文を変換するターゲットメッセージペイロードの型を設定します。 |
void | setUseBroker(boolean useBroker) このアダプターが non-MESSAGE WebSocketMessage に対して既存の単一の AbstractBrokerMessageHandler Bean を使用するかどうか、およびブローカー宛先を使用してメッセージをルーティングするかどうかを指定します。 |
afterSingletonsInstantiated, buildErrorMessage, getErrorChannel, getErrorMessageAttributes, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisherdestroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stopafterPropertiesSet, 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, toStringcloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSEgetBeanName, getComponentNamepublic WebSocketInboundChannelAdapter(IntegrationWebSocketContainer webSocketContainer)
public WebSocketInboundChannelAdapter(IntegrationWebSocketContainer webSocketContainer, SubProtocolHandlerRegistry protocolHandlerRegistry)
public void setMessageConverters(ListSE<MessageConverter> messageConverters)
messageConverters - メッセージコンバーター。public void setMergeWithDefaultConverters(boolean mergeWithDefaultConverters)
mergeWithDefaultConverters - マージする場合は true、置き換える場合は false。public void setPayloadType(ClassSE<?> payloadType)
payloadType - 受信 WebSocket メッセージ本文を変換する CompositeMessageConverterpublic void setUseBroker(boolean useBroker)
non-MESSAGE WebSocketMessage に対して既存の単一の AbstractBrokerMessageHandler Bean を使用するかどうか、およびブローカー宛先を使用してメッセージをルーティングするかどうかを指定します。現在のアプリケーションコンテキストでは単一の AbstractBrokerMessageHandler Bean のみが許可されているため、Bean 参照を適用するのではなく、型によって前者をルックアップするアルゴリズム。これはサーバー側でのみ使用され、クライアント側では無視されます。useBroker - ブールフラグ。public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
ApplicationEventPublisherAware の setApplicationEventPublisher protected void onInit()
IntegrationObjectSupportMessageProducerSupport の onInit public ListSE<StringSE> getSubProtocols()
SubProtocolCapable の getSubProtocols public void afterSessionStarted(WebSocketSession session) throws ExceptionSE
WebSocketListenerWebSocketSession が開始した後に呼び出されます。WebSocketListener の afterSessionStarted session - WebSocket セッション ExceptionSE - "afterSessionStarted" 例外 public void afterSessionEnded(WebSocketSession session, CloseStatus closeStatus) throws ExceptionSE
WebSocketListenerWebSocketSession が終了した後に呼び出されます。WebSocketListener の afterSessionEnded session - WebSocket セッション closeStatus - セッションが閉じられた理由 ExceptionSE - "afterSessionEnded" 例外 public void onMessage(WebSocketSession session, WebSocketMessage<?> webSocketMessage) throws ExceptionSE
WebSocketListenerWebSocketMessage を処理します。WebSocketListener の onMessage session - WebSocket セッション webSocketMessage - WebSocket メッセージ ExceptionSE - "onMessage" 例外 public StringSE getComponentType()
IntegrationObjectSupportNamedComponent の getComponentType IntegrationObjectSupport の getComponentType protected void doStart()
MessageProducerSupportMessageProducerSupport の doStart protected void doStop()
MessageProducerSupportMessageProducerSupport の doStop