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