インターフェースの使用
org.springframework.messaging.MessageChannel
パッケージ
説明
メッセージング API およびプロトコルの使用のサポート。
メッセージングテンプレートのインターフェースと実装クラスを定義します。
STOMP などのプロトコルを含む Simple Messaging Protocols の一般的なサポート。
シンプルなメッセージングプロトコル(STOMP など)からのメッセージを処理するためのクラスをサポートします。
「単純な」メッセージブローカの実装を、抽象基本クラスおよびサブスクリプションのレジストリなどの他のサポート型とともに提供します。
より高いレベルのメッセージングプロトコルを使用した WebSocket メッセージングの構成サポート。
シンプルなメッセージングプロトコル(STOMP など)の一般的なサポート。
Message
の実装と、MessageBuilder および MessageHeaderAccessor を実装して、メッセージおよびメッセージヘッダーの構築と操作、さまざまな MessageChannel
実装およびチャネルインターセプターサポートを提供します。Spring のメッセージングモジュール用の WebSocket 統合。
org.springframework.messaging 内の MessageChannel 使用
修飾子と型インターフェース説明interface
ポーリングを通じてメッセージをアクティブに受信できるMessageChannel
。interface
サブスクライバーのレジストリを維持し、呼び出してこのチャネルを介して送信されるメッセージを処理するMessageChannel
。org.springframework.messaging.core 内の MessageChannel 使用
修飾子と型メソッド説明protected final Message<?>
GenericMessagingTemplate.doReceive
(MessageChannel channel) protected final Message<?>
GenericMessagingTemplate.doReceive
(MessageChannel channel, long timeout) protected final void
GenericMessagingTemplate.doSend
(MessageChannel channel, Message<?> message) protected final void
GenericMessagingTemplate.doSend
(MessageChannel channel, Message<?> message, long timeout) protected final Message<?>
GenericMessagingTemplate.doSendAndReceive
(MessageChannel channel, Message<?> requestMessage) org.springframework.messaging.simp 内の MessageChannel 使用
修飾子コンストラクター説明SimpMessagingTemplate
(MessageChannel messageChannel) 新しいSimpMessagingTemplate
インスタンスを作成します。org.springframework.messaging.simp.annotation.support 内の MessageChannel 使用
修飾子コンストラクター説明SimpAnnotationMethodMessageHandler
(SubscribableChannel clientInboundChannel, MessageChannel clientOutboundChannel, SimpMessageSendingOperations brokerTemplate) 指定されたメッセージチャネルとブローカーメッセージングテンプレートを使用して SimpAnnotationMethodMessageHandler のインスタンスを作成します。org.springframework.messaging.simp.broker 内の MessageChannel 使用
修飾子と型メソッド説明AbstractBrokerMessageHandler.getClientOutboundChannel()
protected MessageChannel
AbstractBrokerMessageHandler.getClientOutboundChannelForSession
(StringSE sessionId) クライアントへのメッセージ送信に使用する MessageChannel を取得します。preservePublishOrder=true
の場合はセッションごとのラッパーです。修飾子と型メソッド説明static void
OrderedMessageChannelDecorator.configureInterceptor
(MessageChannel channel, boolean preserveOrder) メッセージのヘッダーにある場合は、完了タスクを呼び出すExecutorChannelInterceptor
をインストールまたは削除します。static boolean
OrderedMessageChannelDecorator.supportsOrderedMessages
(MessageChannel channel) チャネルが順次処理用のインターセプターを備えたconfigured
であるかどうか。修飾子コンストラクター説明AbstractBrokerMessageHandler
(SubscribableChannel inboundChannel, MessageChannel outboundChannel, SubscribableChannel brokerChannel) 宛先プレフィックスのないコンストラクター(すべての宛先に一致)。AbstractBrokerMessageHandler
(SubscribableChannel inboundChannel, MessageChannel outboundChannel, SubscribableChannel brokerChannel, CollectionSE<StringSE> destinationPrefixes) メッセージの宛先に一致する宛先プレフィックスを持つコンストラクター。OrderedMessageChannelDecorator
(MessageChannel channel, Log logger) SimpleBrokerMessageHandler
(SubscribableChannel clientInboundChannel, MessageChannel clientOutboundChannel, SubscribableChannel brokerChannel, CollectionSE<StringSE> destinationPrefixes) 指定されたメッセージチャネルと宛先プレフィックスを使用して SimpleBrokerMessageHandler インスタンスを作成します。org.springframework.messaging.simp.config 内の MessageChannel 使用
修飾子コンストラクター説明AbstractBrokerRegistration
(SubscribableChannel clientInboundChannel, MessageChannel clientOutboundChannel, StringSE[] destinationPrefixes) 新しいブローカー登録を作成します。MessageBrokerRegistry
(SubscribableChannel clientInboundChannel, MessageChannel clientOutboundChannel) SimpleBrokerRegistration
(SubscribableChannel clientInboundChannel, MessageChannel clientOutboundChannel, StringSE[] destinationPrefixes) 新しいSimpleBrokerRegistration
を作成します。StompBrokerRelayRegistration
(SubscribableChannel clientInboundChannel, MessageChannel clientOutboundChannel, StringSE[] destinationPrefixes) 新しいStompBrokerRelayRegistration
を作成します。org.springframework.messaging.simp.stomp 内の MessageChannel 使用
修飾子コンストラクター説明StompBrokerRelayMessageHandler
(SubscribableChannel inboundChannel, MessageChannel outboundChannel, SubscribableChannel brokerChannel, CollectionSE<StringSE> destinationPrefixes) 指定されたメッセージチャネルと宛先プレフィックスを使用して StompBrokerRelayMessageHandler インスタンスを作成します。org.springframework.messaging.support 内の MessageChannel 使用
修飾子と型クラス説明class
MessageChannel
実装の抽象基本クラス。class
SubscribableChannel
実装の抽象基本クラス。class
各サブスクライバーにメッセージを送信するSubscribableChannel
。修飾子と型メソッド説明default void
ExecutorChannelInterceptor.afterMessageHandled
(Message<?> message, MessageChannel channel, MessageHandler handler, ExceptionSE ex) 結果に関係なくターゲット MessageHandler を呼び出した後、Executor に送信されたRunnable
SE 内で呼び出されます(つまりdefault void
ChannelInterceptor.afterReceiveCompletion
(Message<?> message, MessageChannel channel, ExceptionSE ex) 発生した例外に関係なく、受信の完了後に呼び出されるため、適切なリソースのクリーンアップが可能になります。default void
ChannelInterceptor.afterSendCompletion
(Message<?> message, MessageChannel channel, boolean sent, ExceptionSE ex) 発生した例外に関係なく、送信の完了後に呼び出され、適切なリソースクリーンアップが可能になります。Message<?>
AbstractMessageChannel.ChannelInterceptorChain.applyPostReceive
(Message<?> message, MessageChannel channel) void
AbstractMessageChannel.ChannelInterceptorChain.applyPostSend
(Message<?> message, MessageChannel channel, boolean sent) boolean
AbstractMessageChannel.ChannelInterceptorChain.applyPreReceive
(MessageChannel channel) Message<?>
AbstractMessageChannel.ChannelInterceptorChain.applyPreSend
(Message<?> message, MessageChannel channel) default Message<?>
ExecutorChannelInterceptor.beforeHandle
(Message<?> message, MessageChannel channel, MessageHandler handler) ターゲット MessageHandler を呼び出してメッセージを処理する直前に、Executor に送信されたRunnable
SE 内で呼び出されます。default Message<?>
ChannelInterceptor.postReceive
(Message<?> message, MessageChannel channel) Message が取得された直後、呼び出し元に返される前に呼び出されます。default void
ChannelInterceptor.postSend
(Message<?> message, MessageChannel channel, boolean sent) 送信呼び出しの直後に呼び出されます。default boolean
ChannelInterceptor.preReceive
(MessageChannel channel) receive が呼び出されるとすぐに、Message が実際に取得される前に呼び出されます。default Message<?>
ChannelInterceptor.preSend
(Message<?> message, MessageChannel channel) メッセージが実際にチャネルに送信される前に呼び出されます。Message<?>
ImmutableMessageChannelInterceptor.preSend
(Message<?> message, MessageChannel channel) MessageBuilder.setErrorChannel
(MessageChannel errorChannel) void
MessageHeaderAccessor.setErrorChannel
(MessageChannel errorChannel) MessageBuilder.setReplyChannel
(MessageChannel replyChannel) void
MessageHeaderAccessor.setReplyChannel
(MessageChannel replyChannel) void
AbstractMessageChannel.ChannelInterceptorChain.triggerAfterReceiveCompletion
(Message<?> message, MessageChannel channel, ExceptionSE ex) void
AbstractMessageChannel.ChannelInterceptorChain.triggerAfterSendCompletion
(Message<?> message, MessageChannel channel, boolean sent, ExceptionSE ex) org.springframework.web.socket.messaging 内の MessageChannel 使用
修飾子と型メソッド説明void
StompSubProtocolHandler.afterSessionEnded
(WebSocketSession session, CloseStatus closeStatus, MessageChannel outputChannel) void
SubProtocolHandler.afterSessionEnded
(WebSocketSession session, CloseStatus closeStatus, MessageChannel outputChannel) WebSocketSession
が終了した後に呼び出されます。void
StompSubProtocolHandler.afterSessionStarted
(WebSocketSession session, MessageChannel outputChannel) void
SubProtocolHandler.afterSessionStarted
(WebSocketSession session, MessageChannel outputChannel) WebSocketSession
が開始した後に呼び出されます。void
StompSubProtocolHandler.handleMessageFromClient
(WebSocketSession session, WebSocketMessage<?> webSocketMessage, MessageChannel targetChannel) クライアントからの受信 WebSocket メッセージを処理します。void
SubProtocolHandler.handleMessageFromClient
(WebSocketSession session, WebSocketMessage<?> message, MessageChannel outputChannel) クライアントから受信した特定のWebSocketMessage
を処理します。修飾子コンストラクター説明SubProtocolWebSocketHandler
(MessageChannel clientInboundChannel, SubscribableChannel clientOutboundChannel) 指定された受信および送信チャネル用に新しいSubProtocolWebSocketHandler
を作成します。WebSocketAnnotationMethodMessageHandler
(SubscribableChannel clientInChannel, MessageChannel clientOutChannel, SimpMessageSendingOperations brokerTemplate)