インターフェースの使用
org.springframework.messaging.Message
パッケージ
説明
JMS サポートのコアパッケージ。
ターゲットリスナーメソッドに委譲し、メッセージをリスナーメソッドに渡される適切なメッセージコンテンツ型(文字列やバイト配列など)に変換するメッセージリスナーアダプターメカニズム。
このパッケージは、JmsTemplate のような上位レベルのクラスで使用される汎用 JMS サポートクラスを提供します。
メッセージング API およびプロトコルの使用のサポート。
メッセージ変換のサポートを提供します。
メッセージングテンプレートのインターフェースと実装クラスを定義します。
メッセージハンドラーメソッドを操作するための基本的な抽象概念。
ノンブロッキング、リアクティブ契約でアノテーション付きメッセージ処理メソッドを操作するためのサポートクラス。
アノテーション付きのメッセージ処理メソッドを操作するためのクラスをサポートします。
メッセージハンドラーメソッドを呼び出すための共通インフラストラクチャ。
ノンブロッキング、リアクティブ契約でメッセージハンドラーメソッドを呼び出すための共通インフラストラクチャ。
アノテーション付き RSocket ストリーム処理メソッドを操作するためのクラスをサポートします。
STOMP などのプロトコルを含む Simple Messaging Protocols の一般的なサポート。
シンプルなメッセージングプロトコル(STOMP など)からのメッセージを処理するためのクラスをサポートします。
「単純な」メッセージブローカの実装を、抽象基本クラスおよびサブスクリプションのレジストリなどの他のサポート型とともに提供します。
シンプルなメッセージングプロトコル(STOMP など)の一般的なサポート。
「ユーザー」宛先へのメッセージの処理のサポート(つまり
Message
の実装と、MessageBuilder および MessageHeaderAccessor を実装して、メッセージおよびメッセージヘッダーの構築と操作、さまざまな MessageChannel
実装およびチャネルインターセプターサポートを提供します。TcpOperations
を介して TCP 接続を確立し、TcpConnectionHandler
を介してメッセージを処理し、TcpConnection
を介してメッセージを送信するための抽象化と実装クラスが含まれています。Reactor に基づく TCP メッセージングのサポートが含まれています。
Spring のメッセージングモジュール用の WebSocket 統合。
org.springframework.jms.core 内の Message 使用
修飾子と型メソッド説明protected Message<?>
JmsMessagingTemplate.convertJmsMessage
(MessageEE message) protected Message<?>
JmsMessagingTemplate.doReceive
(DestinationEE destination) protected Message<?>
protected Message<?>
JmsMessagingTemplate.doSendAndReceive
(DestinationEE destination, Message<?> requestMessage) protected Message<?>
JmsMessagingTemplate.doSendAndReceive
(StringSE destinationName, Message<?> requestMessage) Message<?>
指定された宛先からメッセージを受信します。Message<?>
JmsMessagingTemplate.receive()
Message<?>
Message<?>
JmsMessageOperations.sendAndReceive
(StringSE destinationName, Message<?> requestMessage) リクエストメッセージを送信し、指定された宛先から応答を受信します。Message<?>
JmsMessagingTemplate.sendAndReceive
(StringSE destinationName, Message<?> requestMessage) Message<?>
JmsMessagingTemplate.sendAndReceive
(Message<?> requestMessage) 修飾子と型メソッド説明protected void
JmsMessagingTemplate.doSend
(DestinationEE destination, Message<?> message) protected void
protected Message<?>
JmsMessagingTemplate.doSendAndReceive
(DestinationEE destination, Message<?> requestMessage) protected Message<?>
JmsMessagingTemplate.doSendAndReceive
(StringSE destinationName, Message<?> requestMessage) void
指定された宛先にメッセージを送信します。void
void
Message<?>
JmsMessageOperations.sendAndReceive
(StringSE destinationName, Message<?> requestMessage) リクエストメッセージを送信し、指定された宛先から応答を受信します。Message<?>
JmsMessagingTemplate.sendAndReceive
(StringSE destinationName, Message<?> requestMessage) Message<?>
JmsMessagingTemplate.sendAndReceive
(Message<?> requestMessage) org.springframework.jms.listener.adapter 内の Message 使用
修飾子と型メソッド説明protected Message<?>
MessagingMessageListenerAdapter.toMessagingMessage
(MessageEE jmsMessage) org.springframework.jms.support 内の Message 使用
org.springframework.messaging 内の Message 使用
修飾子と型メソッド説明Message<?>
MessagingException.getFailedMessage()
Message<?>
PollableChannel.receive()
このチャネルからメッセージを受信し、必要に応じて無期限にブロックします。Message<?>
PollableChannel.receive
(long timeout) このチャネルからメッセージを受信し、メッセージが利用可能になるか、指定されたタイムアウト期間が経過するまでブロックします。修飾子と型メソッド説明void
MessageHandler.handleMessage
(Message<?> message) 指定されたメッセージを処理します。reactor.core.publisher.Mono<VoidSE>
ReactiveMessageHandler.handleMessage
(Message<?> message) 指定されたメッセージを処理します。default boolean
Message
をこのチャネルに送信します。boolean
メッセージを送信し、メッセージが受け入れられるか、指定されたタイムアウト期間が経過するまでブロックします。修飾子コンストラクター説明MessageDeliveryException
(Message<?> undeliveredMessage) MessageDeliveryException
(Message<?> undeliveredMessage, StringSE description) MessageDeliveryException
(Message<?> undeliveredMessage, StringSE description, ThrowableSE cause) MessageDeliveryException
(Message<?> message, ThrowableSE cause) MessageHandlingException
(Message<?> failedMessage) MessageHandlingException
(Message<?> message, StringSE description) MessageHandlingException
(Message<?> message, StringSE description, ThrowableSE cause) MessageHandlingException
(Message<?> failedMessage, ThrowableSE cause) MessagingException
(Message<?> message) MessagingException
(Message<?> message, StringSE description) MessagingException
(Message<?> message, StringSE description, ThrowableSE cause) MessagingException
(Message<?> message, ThrowableSE cause) org.springframework.messaging.converter 内の Message 使用
修飾子と型メソッド説明final Message<?>
AbstractMessageConverter.toMessage
(ObjectSE payload, MessageHeaders headers) final Message<?>
AbstractMessageConverter.toMessage
(ObjectSE payload, MessageHeaders headers, ObjectSE conversionHint) Message<?>
CompositeMessageConverter.toMessage
(ObjectSE payload, MessageHeaders headers) Message<?>
CompositeMessageConverter.toMessage
(ObjectSE payload, MessageHeaders headers, ObjectSE conversionHint) Message<?>
MessageConverter.toMessage
(ObjectSE payload, MessageHeaders headers) ペイロードが特定のペイロードオブジェクトを直列化された形式に変換した結果であるMessage
を作成します。Message<?>
SimpleMessageConverter.toMessage
(ObjectSE payload, MessageHeaders headers) Message<?>
SmartMessageConverter.toMessage
(ObjectSE payload, MessageHeaders headers, ObjectSE conversionHint) MessageConverter.toMessage(Object, MessageHeaders)
のバリアントで、追加の変換コンテキストを引数として受け取り、たとえば戻り値の型のアノテーションを考慮に入れることができます。修飾子と型メソッド説明protected boolean
AbstractMessageConverter.canConvertFrom
(Message<?> message, ClassSE<?> targetClass) protected boolean
MappingJackson2MessageConverter.canConvertFrom
(Message<?> message, ClassSE<?> targetClass) protected boolean
MarshallingMessageConverter.canConvertFrom
(Message<?> message, ClassSE<?> targetClass) protected ObjectSE
AbstractJsonMessageConverter.convertFromInternal
(Message<?> message, ClassSE<?> targetClass, ObjectSE conversionHint) protected ObjectSE
AbstractMessageConverter.convertFromInternal
(Message<?> message, ClassSE<?> targetClass, ObjectSE conversionHint) メッセージペイロードを直列化された形式からオブジェクトに変換します。protected ObjectSE
ByteArrayMessageConverter.convertFromInternal
(Message<?> message, ClassSE<?> targetClass, ObjectSE conversionHint) protected ObjectSE
MappingJackson2MessageConverter.convertFromInternal
(Message<?> message, ClassSE<?> targetClass, ObjectSE conversionHint) protected ObjectSE
MarshallingMessageConverter.convertFromInternal
(Message<?> message, ClassSE<?> targetClass, ObjectSE conversionHint) protected ObjectSE
ProtobufMessageConverter.convertFromInternal
(Message<?> message, ClassSE<?> targetClass, ObjectSE conversionHint) protected ObjectSE
StringMessageConverter.convertFromInternal
(Message<?> message, ClassSE<?> targetClass, ObjectSE conversionHint) final ObjectSE
AbstractMessageConverter.fromMessage
(Message<?> message, ClassSE<?> targetClass) final ObjectSE
AbstractMessageConverter.fromMessage
(Message<?> message, ClassSE<?> targetClass, ObjectSE conversionHint) CompositeMessageConverter.fromMessage
(Message<?> message, ClassSE<?> targetClass) CompositeMessageConverter.fromMessage
(Message<?> message, ClassSE<?> targetClass, ObjectSE conversionHint) GenericMessageConverter.fromMessage
(Message<?> message, ClassSE<?> targetClass) MessageConverter.fromMessage
(Message<?> message, ClassSE<?> targetClass) Message
のペイロードを、直列化された形式から、指定されたターゲットクラスの型付きオブジェクトに変換します。SimpleMessageConverter.fromMessage
(Message<?> message, ClassSE<?> targetClass) SmartMessageConverter.fromMessage
(Message<?> message, ClassSE<?> targetClass, ObjectSE conversionHint) MessageConverter.fromMessage(Message, Class)
のバリアントで、追加の変換コンテキストを引数として受け取り、たとえばペイロードパラメーターのアノテーションを考慮に入れることができます。修飾子コンストラクター説明MessageConversionException
(Message<?> failedMessage, StringSE description) MessageConversionException
(Message<?> failedMessage, StringSE description, ThrowableSE cause) org.springframework.messaging.core 内の Message 使用
修飾子と型メソッド説明protected Message<?>
AbstractMessageSendingTemplate.doConvert
(ObjectSE payload, MapSE<StringSE, ObjectSE> headers, MessagePostProcessor postProcessor) おそらくMessageConverter
を使用して、指定されたオブジェクトを直列化された形式に変換し、指定されたヘッダーを持つメッセージとしてラップし、指定されたポストプロセッサーを適用します。protected abstract Message<?>
実際に、指定された宛先からメッセージを受信します。protected final Message<?>
GenericMessagingTemplate.doReceive
(MessageChannel channel) protected final Message<?>
GenericMessagingTemplate.doReceive
(MessageChannel channel, long timeout) protected abstract Message<?>
AbstractMessagingTemplate.doSendAndReceive
(D destination, Message<?> requestMessage) protected final Message<?>
GenericMessagingTemplate.doSendAndReceive
(MessageChannel channel, Message<?> requestMessage) Message<?>
MessagePostProcessor.postProcessMessage
(Message<?> message) 指定されたメッセージを処理します。Message<?>
Message<?>
AbstractMessageReceivingTemplate.receive()
Message<?>
Message<?>
指定された宛先名を解決し、そこからメッセージを受信します。Message<?>
MessageReceivingOperations.receive()
デフォルトの宛先からメッセージを受信します。Message<?>
指定された宛先からメッセージを受信します。Message<?>
AbstractDestinationResolvingMessagingTemplate.sendAndReceive
(StringSE destinationName, Message<?> requestMessage) Message<?>
AbstractMessagingTemplate.sendAndReceive
(D destination, Message<?> requestMessage) Message<?>
AbstractMessagingTemplate.sendAndReceive
(Message<?> requestMessage) Message<?>
DestinationResolvingMessageRequestReplyOperations.sendAndReceive
(StringSE destinationName, Message<?> requestMessage) 指定された宛先名を宛先に解決し、指定されたメッセージを送信し、応答を受信して返します。Message<?>
MessageRequestReplyOperations.sendAndReceive
(D destination, Message<?> requestMessage) リクエストメッセージを送信し、指定された宛先から応答を受信します。Message<?>
MessageRequestReplyOperations.sendAndReceive
(Message<?> requestMessage) リクエストメッセージを送信し、デフォルトの宛先から応答を受信します。修飾子と型メソッド説明protected <T> T
指定されたメッセージから指定されたターゲットクラスに変換します。protected abstract void
protected final void
GenericMessagingTemplate.doSend
(MessageChannel channel, Message<?> message) protected final void
GenericMessagingTemplate.doSend
(MessageChannel channel, Message<?> message, long timeout) protected abstract Message<?>
AbstractMessagingTemplate.doSendAndReceive
(D destination, Message<?> requestMessage) protected final Message<?>
GenericMessagingTemplate.doSendAndReceive
(MessageChannel channel, Message<?> requestMessage) Message<?>
MessagePostProcessor.postProcessMessage
(Message<?> message) 指定されたメッセージを処理します。void
void
void
void
指定された宛先名を宛先に解決し、メッセージを送信します。void
指定された宛先にメッセージを送信します。void
デフォルトの宛先にメッセージを送信します。Message<?>
AbstractDestinationResolvingMessagingTemplate.sendAndReceive
(StringSE destinationName, Message<?> requestMessage) Message<?>
AbstractMessagingTemplate.sendAndReceive
(D destination, Message<?> requestMessage) Message<?>
AbstractMessagingTemplate.sendAndReceive
(Message<?> requestMessage) Message<?>
DestinationResolvingMessageRequestReplyOperations.sendAndReceive
(StringSE destinationName, Message<?> requestMessage) 指定された宛先名を宛先に解決し、指定されたメッセージを送信し、応答を受信して返します。Message<?>
MessageRequestReplyOperations.sendAndReceive
(D destination, Message<?> requestMessage) リクエストメッセージを送信し、指定された宛先から応答を受信します。Message<?>
MessageRequestReplyOperations.sendAndReceive
(Message<?> requestMessage) リクエストメッセージを送信し、デフォルトの宛先から応答を受信します。org.springframework.messaging.handler 内の Message 使用
修飾子と型メソッド説明int
CompositeMessageCondition.compareTo
(CompositeMessageCondition other, Message<?> message) int
DestinationPatternsMessageCondition.compareTo
(DestinationPatternsMessageCondition other, Message<?> message) 含まれる宛先パターンに基づいて 2 つの条件を比較します。int
特定のメッセージのコンテキストでこの条件を別の条件と比較します。CompositeMessageCondition.getMatchingCondition
(Message<?> message) DestinationPatternsMessageCondition.getMatchingCondition
(Message<?> message) 指定されたメッセージの宛先に一致するパターンがあるかどうかを確認し、PathMatcher.getPatternComparator(String)
でソートされた一致するパターンを含むことが保証されているインスタンスを返します。MessageCondition.getMatchingCondition
(Message<?> message) この条件が指定されたメッセージと一致しているかどうかを確認し、現在のメッセージに合わせた内容を持つ潜在的に新しい条件を返します。org.springframework.messaging.handler.annotation.reactive 内の Message 使用
修飾子と型メソッド説明protected RouteMatcher.Route
MessageMappingMessageHandler.getDestination
(Message<?> message) protected ComparatorSE<CompositeMessageCondition>
MessageMappingMessageHandler.getMappingComparator
(Message<?> message) protected CompositeMessageCondition
MessageMappingMessageHandler.getMatchingMapping
(CompositeMessageCondition mapping, Message<?> message) protected MimeType
PayloadMethodArgumentResolver.getMimeType
(Message<?> message) コンテンツの MIME 型を返します。protected reactor.core.publisher.Mono<VoidSE>
MessageMappingMessageHandler.handleMatch
(CompositeMessageCondition mapping, HandlerMethod handlerMethod, Message<?> message) protected abstract void
AbstractNamedValueMethodArgumentResolver.handleMissingValue
(StringSE name, MethodParameter parameter, Message<?> message) 値が必要なときに呼び出されますが、AbstractNamedValueMethodArgumentResolver.resolveArgumentInternal(org.springframework.core.MethodParameter, org.springframework.messaging.Message<?>, java.lang.String)
はnull
を返し、デフォルト値はありません。protected void
DestinationVariableMethodArgumentResolver.handleMissingValue
(StringSE name, MethodParameter parameter, Message<?> message) protected void
HeaderMethodArgumentResolver.handleMissingValue
(StringSE headerName, MethodParameter parameter, Message<?> message) reactor.core.publisher.Mono<ObjectSE>
ContinuationHandlerMethodArgumentResolver.resolveArgument
(MethodParameter parameter, Message<?> message) final reactor.core.publisher.Mono<ObjectSE>
PayloadMethodArgumentResolver.resolveArgument
(MethodParameter parameter, Message<?> message) 互換性のあるDecoder
を介して、指定されたメッセージペイロードの内容をデコードします。protected abstract ObjectSE
AbstractNamedValueMethodArgumentResolver.resolveArgumentInternal
(MethodParameter parameter, Message<?> message, StringSE name) 指定されたパラメーターの型と値の名前を引数値に解決します。protected ObjectSE
DestinationVariableMethodArgumentResolver.resolveArgumentInternal
(MethodParameter parameter, Message<?> message, StringSE name) protected ObjectSE
HeaderMethodArgumentResolver.resolveArgumentInternal
(MethodParameter parameter, Message<?> message, StringSE name) AbstractNamedValueMethodArgumentResolver.resolveArgumentValue
(MethodParameter parameter, Message<?> message) HeadersMethodArgumentResolver.resolveArgumentValue
(MethodParameter parameter, Message<?> message) org.springframework.messaging.handler.annotation.support 内の Message 使用
修飾子と型メソッド説明protected ClassSE<?>
MessageMethodArgumentResolver.getPayloadType
(MethodParameter parameter, Message<?> message) ペイロードを変換するターゲットクラスを解決します。protected abstract void
AbstractNamedValueMethodArgumentResolver.handleMissingValue
(StringSE name, MethodParameter parameter, Message<?> message) 値が必要なときに呼び出されますが、AbstractNamedValueMethodArgumentResolver.resolveArgumentInternal(org.springframework.core.MethodParameter, org.springframework.messaging.Message<?>, java.lang.String)
はnull
を返し、デフォルト値はありません。protected void
DestinationVariableMethodArgumentResolver.handleMissingValue
(StringSE name, MethodParameter parameter, Message<?> message) protected void
HeaderMethodArgumentResolver.handleMissingValue
(StringSE headerName, MethodParameter parameter, Message<?> message) protected void
AbstractNamedValueMethodArgumentResolver.handleResolvedValue
(ObjectSE arg, StringSE name, MethodParameter parameter, Message<?> message) 値が解決された後に呼び出されます。AbstractNamedValueMethodArgumentResolver.resolveArgument
(MethodParameter parameter, Message<?> message) HeadersMethodArgumentResolver.resolveArgument
(MethodParameter parameter, Message<?> message) MessageMethodArgumentResolver.resolveArgument
(MethodParameter parameter, Message<?> message) PayloadMethodArgumentResolver.resolveArgument
(MethodParameter parameter, Message<?> message) protected abstract ObjectSE
AbstractNamedValueMethodArgumentResolver.resolveArgumentInternal
(MethodParameter parameter, Message<?> message, StringSE name) 指定されたパラメーターの型と値の名前を引数値に解決します。protected ObjectSE
DestinationVariableMethodArgumentResolver.resolveArgumentInternal
(MethodParameter parameter, Message<?> message, StringSE name) protected ObjectSE
HeaderMethodArgumentResolver.resolveArgumentInternal
(MethodParameter parameter, Message<?> message, StringSE name) protected ClassSE<?>
PayloadMethodArgumentResolver.resolveTargetClass
(MethodParameter parameter, Message<?> message) ペイロードを変換するターゲットクラスを解決します。protected void
PayloadMethodArgumentResolver.validate
(Message<?> message, MethodParameter parameter, ObjectSE target) 該当する場合、ペイロードを検証します。修飾子コンストラクター説明MethodArgumentNotValidException
(Message<?> message, MethodParameter parameter) 無効なMethodParameter
を使用して新しいインスタンスを作成します。MethodArgumentNotValidException
(Message<?> message, MethodParameter parameter, BindingResult bindingResult) 無効なMethodParameter
とBindingResult
で新しいインスタンスを作成します。MethodArgumentTypeMismatchException
(Message<?> message, MethodParameter parameter, StringSE description) org.springframework.messaging.handler.invocation 内の Message 使用
修飾子と型メソッド説明protected abstract StringSE
AbstractMethodMessageHandler.getDestination
(Message<?> message) protected abstract ComparatorSE<T>
AbstractMethodMessageHandler.getMappingComparator
(Message<?> message) 一致するマッピングをソートするためのコンパレーターを返します。protected abstract T
AbstractMethodMessageHandler.getMatchingMapping
(T mapping, Message<?> message) マッピングが現在のメッセージと一致するかどうかを確認し、現在のリクエストに関連する条件を含む新しいマッピングを返す可能性があります。protected ObjectSE[]
InvocableHandlerMethod.getMethodArgumentValues
(Message<?> message, ObjectSE... providedArgs) 現在のメッセージのメソッド引数値を取得し、提供された引数値を確認して、構成された引数リゾルバーにフォールバックします。protected void
AbstractMethodMessageHandler.handleMatch
(T mapping, HandlerMethod handlerMethod, StringSE lookupDestination, Message<?> message) void
AbstractMethodMessageHandler.handleMessage
(Message<?> message) protected void
AbstractMethodMessageHandler.handleMessageInternal
(Message<?> message, StringSE lookupDestination) protected void
AbstractMethodMessageHandler.handleNoMatch
(SetSE<T> ts, StringSE lookupDestination, Message<?> message) void
AbstractAsyncReturnValueHandler.handleReturnValue
(ObjectSE returnValue, MethodParameter returnType, Message<?> message) void
HandlerMethodReturnValueHandler.handleReturnValue
(ObjectSE returnValue, MethodParameter returnType, Message<?> message) 指定された戻り値を処理します。void
HandlerMethodReturnValueHandlerComposite.handleReturnValue
(ObjectSE returnValue, MethodParameter returnType, Message<?> message) 指定されたメッセージのコンテキストで引数値を解決した後、メソッドを呼び出します。protected void
AbstractMethodMessageHandler.processHandlerMethodException
(HandlerMethod handlerMethod, ExceptionSE exception, Message<?> message) HandlerMethodArgumentResolver.resolveArgument
(MethodParameter parameter, Message<?> message) メソッドパラメーターを特定のメッセージの引数値に解決します。HandlerMethodArgumentResolverComposite.resolveArgument
(MethodParameter parameter, Message<?> message) 登録されたHandlerMethodArgumentResolvers
を反復処理し、それをサポートするHandlerMethodArgumentResolvers
を呼び出します。修飾子コンストラクター説明MethodArgumentResolutionException
(Message<?> message, MethodParameter parameter) 無効なMethodParameter
を提供する新しいインスタンスを作成します。MethodArgumentResolutionException
(Message<?> message, MethodParameter parameter, StringSE description) 無効なMethodParameter
と準備された説明を提供する新しいインスタンスを作成します。MethodArgumentResolutionException
(Message<?> message, MethodParameter parameter, StringSE description, ThrowableSE cause) 無効なMethodParameter
、準備された説明、原因を提供する新しいインスタンスを作成します。org.springframework.messaging.handler.invocation.reactive 内の Message 使用
修飾子と型メソッド説明protected abstract RouteMatcher.Route
AbstractMethodMessageHandler.getDestination
(Message<?> message) 指定されたメッセージから宛先を抽出します。protected abstract ComparatorSE<T>
AbstractMethodMessageHandler.getMappingComparator
(Message<?> message) 一致するマッピングをソートするためのコンパレーターを返します。protected abstract T
AbstractMethodMessageHandler.getMatchingMapping
(T mapping, Message<?> message) マッピングが現在のメッセージと一致するかどうかを確認し、現在のリクエストに関連する条件を含む新しいマッピングを返す可能性があります。protected abstract reactor.core.publisher.Mono<VoidSE>
AbstractEncoderMethodReturnValueHandler.handleEncodedContent
(reactor.core.publisher.Flux<DataBuffer> encodedContent, MethodParameter returnType, Message<?> message) サブクラスは、このメソッドを実装して、メッセージの作成や送信などの何らかの方法でエンコードされた値を処理します。protected reactor.core.publisher.Mono<VoidSE>
AbstractMethodMessageHandler.handleMatch
(T mapping, HandlerMethod handlerMethod, Message<?> message) reactor.core.publisher.Mono<VoidSE>
AbstractMethodMessageHandler.handleMessage
(Message<?> message) protected abstract reactor.core.publisher.Mono<VoidSE>
AbstractEncoderMethodReturnValueHandler.handleNoContent
(MethodParameter returnType, Message<?> message) null
戻り値に対して呼び出されます。これは、void メソッド、または void でパラメーター化された非同期型を返すメソッドを意味する場合があります。protected void
AbstractMethodMessageHandler.handleNoMatch
(RouteMatcher.Route destination, Message<?> message) 一致するハンドラーが見つからないときに呼び出されます。reactor.core.publisher.Mono<VoidSE>
AbstractEncoderMethodReturnValueHandler.handleReturnValue
(ObjectSE returnValue, MethodParameter returnType, Message<?> message) reactor.core.publisher.Mono<VoidSE>
HandlerMethodReturnValueHandler.handleReturnValue
(ObjectSE returnValue, MethodParameter returnType, Message<?> message) 指定された戻り値を処理します。reactor.core.publisher.Mono<VoidSE>
HandlerMethodReturnValueHandlerComposite.handleReturnValue
(ObjectSE returnValue, MethodParameter returnType, Message<?> message) reactor.core.publisher.Mono<ObjectSE>
指定された交換のメソッドを呼び出します。reactor.core.publisher.Mono<ObjectSE>
HandlerMethodArgumentResolver.resolveArgument
(MethodParameter parameter, Message<?> message) メソッドパラメーターを特定のメッセージの引数値に解決します。reactor.core.publisher.Mono<ObjectSE>
HandlerMethodArgumentResolverComposite.resolveArgument
(MethodParameter parameter, Message<?> message) 登録されたHandlerMethodArgumentResolvers
を反復処理し、それをサポートするHandlerMethodArgumentResolvers
を呼び出します。default reactor.core.publisher.Mono<ObjectSE>
SyncHandlerMethodArgumentResolver.resolveArgument
(MethodParameter parameter, Message<?> message) メソッドパラメーターを特定のメッセージの引数値に解決します。SyncHandlerMethodArgumentResolver.resolveArgumentValue
(MethodParameter parameter, Message<?> message) メソッドパラメーターの値を同期的に解決します。org.springframework.messaging.rsocket.annotation.support 内の Message 使用
修飾子と型メソッド説明int
RSocketFrameTypeMessageCondition.compareTo
(RSocketFrameTypeMessageCondition other, Message<?> message) static io.rsocket.frame.FrameType
RSocketFrameTypeMessageCondition.getFrameType
(Message<?> message) メッセージヘッダーで RSocket フレーム型を見つけます。RSocketFrameTypeMessageCondition.getMatchingCondition
(Message<?> message) protected reactor.core.publisher.Mono<VoidSE>
RSocketPayloadReturnValueHandler.handleEncodedContent
(reactor.core.publisher.Flux<DataBuffer> encodedContent, MethodParameter returnType, Message<?> message) protected reactor.core.publisher.Mono<VoidSE>
RSocketPayloadReturnValueHandler.handleNoContent
(MethodParameter returnType, Message<?> message) protected void
RSocketMessageHandler.handleNoMatch
(RouteMatcher.Route destination, Message<?> message) reactor.core.publisher.Mono<ObjectSE>
RSocketRequesterMethodArgumentResolver.resolveArgument
(MethodParameter parameter, Message<?> message) org.springframework.messaging.simp 内の Message 使用
修飾子と型メソッド説明int
SimpMessageMappingInfo.compareTo
(SimpMessageMappingInfo other, Message<?> message) int
SimpMessageTypeMessageCondition.compareTo
(SimpMessageTypeMessageCondition other, Message<?> message) protected MessageHeaderAccessor
SimpMessageHeaderAccessor.createAccessor
(Message<?> message) protected void
static SimpAttributes
SimpAttributes.fromMessage
(Message<?> message) 指定されたメッセージから SiMP セッション属性を抽出し、SimpAttributes
インスタンスにラップします。SimpMessageMappingInfo.getMatchingCondition
(Message<?> message) SimpMessageTypeMessageCondition.getMatchingCondition
(Message<?> message) void
指定されたメッセージのヘッダーにすでにSimpMessageHeaderAccessor#DESTINATION_HEADER
が含まれている場合、メッセージは変更なしで送信されます。static void
SimpAttributesContextHolder.setAttributesFromMessage
(Message<?> message) 指定されたメッセージから SiMP セッション属性を抽出し、SimpAttributes
インスタンスにラップして、現在のスレッドにバインドします。static SimpMessageHeaderAccessor
メッセージのヘッダーをコピーしてインスタンスを作成します。修飾子コンストラクター説明protected
SimpMessageHeaderAccessor
(Message<?> message) 既存のメッセージヘッダーにアクセスして変更するためのコンストラクター。org.springframework.messaging.simp.annotation.support 内の Message 使用
修飾子と型メソッド説明protected StringSE
SimpAnnotationMethodMessageHandler.getDestination
(Message<?> message) protected ComparatorSE<SimpMessageMappingInfo>
SimpAnnotationMethodMessageHandler.getMappingComparator
(Message<?> message) protected SimpMessageMappingInfo
SimpAnnotationMethodMessageHandler.getMatchingMapping
(SimpMessageMappingInfo mapping, Message<?> message) protected StringSE[]
SendToMethodReturnValueHandler.getTargetDestinations
(AnnotationSE annotation, Message<?> message, StringSE defaultPrefix) protected StringSE
SendToMethodReturnValueHandler.getUserName
(Message<?> message, MessageHeaders headers) protected void
SimpAnnotationMethodMessageHandler.handleMatch
(SimpMessageMappingInfo mapping, HandlerMethod handlerMethod, StringSE lookupDestination, Message<?> message) void
SendToMethodReturnValueHandler.handleReturnValue
(ObjectSE returnValue, MethodParameter returnType, Message<?> message) void
SubscriptionMethodReturnValueHandler.handleReturnValue
(ObjectSE returnValue, MethodParameter returnType, Message<?> message) PrincipalMethodArgumentResolver.resolveArgument
(MethodParameter parameter, Message<?> message) org.springframework.messaging.simp.broker 内の Message 使用
修飾子と型メソッド説明protected abstract void
AbstractSubscriptionRegistry.addSubscriptionInternal
(StringSE sessionId, StringSE subscriptionId, StringSE destination, Message<?> message) protected void
DefaultSubscriptionRegistry.addSubscriptionInternal
(StringSE sessionId, StringSE subscriptionId, StringSE destination, Message<?> message) final MultiValueMap<StringSE,
StringSE> AbstractSubscriptionRegistry.findSubscriptions
(Message<?> message) SubscriptionRegistry.findSubscriptions
(Message<?> message) 指定されたメッセージを受信するすべてのサブスクリプションを検索します。protected abstract MultiValueMap<StringSE,
StringSE> AbstractSubscriptionRegistry.findSubscriptionsInternal
(StringSE destination, Message<?> message) protected MultiValueMap<StringSE,
StringSE> DefaultSubscriptionRegistry.findSubscriptionsInternal
(StringSE destination, Message<?> message) static RunnableSE
OrderedMessageChannelDecorator.getNextMessageTask
(Message<?> message) 見つかった場合は、次のメッセージを解放するタスクを取得します。void
AbstractBrokerMessageHandler.handleMessage
(Message<?> message) protected abstract void
AbstractBrokerMessageHandler.handleMessageInternal
(Message<?> message) protected void
SimpleBrokerMessageHandler.handleMessageInternal
(Message<?> message) final void
AbstractSubscriptionRegistry.registerSubscription
(Message<?> message) void
SubscriptionRegistry.registerSubscription
(Message<?> subscribeMessage) 指定されたメッセージが表すサブスクリプションを登録します。protected abstract void
AbstractSubscriptionRegistry.removeSubscriptionInternal
(StringSE sessionId, StringSE subscriptionId, Message<?> message) protected void
DefaultSubscriptionRegistry.removeSubscriptionInternal
(StringSE sessionId, StringSE subscriptionId, Message<?> message) boolean
boolean
protected void
SimpleBrokerMessageHandler.sendMessageToSubscribers
(StringSE destination, Message<?> message) final void
AbstractSubscriptionRegistry.unregisterSubscription
(Message<?> message) void
SubscriptionRegistry.unregisterSubscription
(Message<?> unsubscribeMessage) サブスクリプションの登録を解除します。org.springframework.messaging.simp.stomp 内の Message 使用
修飾子と型メソッド説明BufferingStompDecoder.decode
(ByteBufferSE newBuffer) 指定されたByteBuffer
から 1 つ以上の STOMP フレームをMessages
のリストにデコードします。StompDecoder.decode
(ByteBufferSE byteBuffer) 指定されたByteBuffer
から 1 つ以上の STOMP フレームをMessages
のリストにデコードします。StompDecoder.decode
(ByteBufferSE byteBuffer, MultiValueMap<StringSE, StringSE> partialMessageHeaders) 指定されたbuffer
から 1 つ以上の STOMP フレームをデコードし、Messages
のリストを返します。StompTcpMessageCodec.decode
(ByteBufferSE nioBuffer) StompReactorNettyCodec.decodeInternal
(ByteBufferSE nioBuffer) 修飾子と型メソッド説明protected MessageHeaderAccessor
StompHeaderAccessor.createAccessor
(Message<?> message) byte[]
指定された STOMPmessage
をbyte[]
にエンコードします。protected ByteBufferSE
StompReactorNettyCodec.encodeInternal
(Message<byte[]> message) void
DefaultStompSession.handleMessage
(Message<byte[]> message) protected void
StompBrokerRelayMessageHandler.handleMessageInternal
(Message<?> message) static StompHeaderAccessor
指定されたメッセージのペイロードとヘッダーからインスタンスを作成します。org.springframework.messaging.simp.user 内の Message 使用
修飾子と型メソッド説明void
UserDestinationMessageHandler.handleMessage
(Message<?> sourceMessage) void
UserRegistryMessageHandler.handleMessage
(Message<?> message) DefaultUserDestinationResolver.resolveDestination
(Message<?> message) UserDestinationResolver.resolveDestination
(Message<?> message) ユーザー宛先を指定したメッセージを、実際の宛先を含む 1 つ以上のメッセージ(アクティブなユーザーセッションごとに 1 つ)に解決します。org.springframework.messaging.support 内の Message 使用
修飾子と型メソッド説明Message<?>
AbstractMessageChannel.ChannelInterceptorChain.applyPostReceive
(Message<?> message, MessageChannel channel) Message<?>
AbstractMessageChannel.ChannelInterceptorChain.applyPreSend
(Message<?> message, MessageChannel channel) default Message<?>
ExecutorChannelInterceptor.beforeHandle
(Message<?> message, MessageChannel channel, MessageHandler handler) ターゲット MessageHandler を呼び出してメッセージを処理する直前に、Executor に送信されたRunnable
SE 内で呼び出されます。MessageBuilder.build()
static <T> Message<T>
MessageBuilder.createMessage
(T payload, MessageHeaders messageHeaders) 指定されたペイロードとMessageHeaders
を使用してメッセージを作成するためのショートカットファクトリメソッド。Message<?>
MessageHandlingRunnable.getMessage()
処理されるメッセージを返します。Message<?>
ErrorMessage.getOriginalMessage()
ErrorMessage が作成されたスタック内のポイントで、元のメッセージ(使用可能な場合)を返します。default Message<?>
ChannelInterceptor.postReceive
(Message<?> message, MessageChannel channel) Message が取得された直後、呼び出し元に返される前に呼び出されます。default Message<?>
ChannelInterceptor.preSend
(Message<?> message, MessageChannel channel) メッセージが実際にチャネルに送信される前に呼び出されます。Message<?>
ImmutableMessageChannelInterceptor.preSend
(Message<?> message, MessageChannel channel) 修飾子と型メソッド説明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) Message<?>
AbstractMessageChannel.ChannelInterceptorChain.applyPreSend
(Message<?> message, MessageChannel channel) default Message<?>
ExecutorChannelInterceptor.beforeHandle
(Message<?> message, MessageChannel channel, MessageHandler handler) ターゲット MessageHandler を呼び出してメッセージを処理する直前に、Executor に送信されたRunnable
SE 内で呼び出されます。protected MessageHeaderAccessor
MessageHeaderAccessor.createAccessor
(Message<?> message) 指定されたメッセージの「ネストされた」アクセサーを構築します。static <T> MessageBuilder<T>
MessageBuilder.fromMessage
(Message<T> message) 提供されたメッセージからコピーされたすべてのヘッダーが事前に入力された新しいMessage
インスタンスのビルダーを作成します。static MessageHeaderAccessor
MessageHeaderAccessor.getAccessor
(Message<?> message) 指定されたMessage
のヘッダーの作成に使用された元のMessageHeaderAccessor
を返します。または、null
が利用できない場合、またはその型が必要な型と一致しない場合は、null
を返します。static <T extends MessageHeaderAccessor>
TMessageHeaderAccessor.getAccessor
(Message<?> message, ClassSE<T> requiredType) 指定されたMessage
のヘッダーの作成に使用された元のMessageHeaderAccessor
を返します。または、null
が利用できない場合、またはその型が必要な型と一致しない場合は、null
を返します。static MessageHeaderAccessor
MessageHeaderAccessor.getMutableAccessor
(Message<?> message) メッセージヘッダーを作成するために使用されるアクセサーの型と一致しようとする、またはメッセージをMessageHeaderAccessor
インスタンスでラップする、指定されたメッセージの可変MessageHeaderAccessor
を返します。default Message<?>
ChannelInterceptor.postReceive
(Message<?> message, MessageChannel channel) Message が取得された直後、呼び出し元に返される前に呼び出されます。default void
ChannelInterceptor.postSend
(Message<?> message, MessageChannel channel, boolean sent) 送信呼び出しの直後に呼び出されます。default Message<?>
ChannelInterceptor.preSend
(Message<?> message, MessageChannel channel) メッセージが実際にチャネルに送信される前に呼び出されます。Message<?>
ImmutableMessageChannelInterceptor.preSend
(Message<?> message, MessageChannel channel) final boolean
final boolean
protected abstract boolean
AbstractMessageChannel.sendInternal
(Message<?> message, long timeout) boolean
ExecutorSubscribableChannel.sendInternal
(Message<?> message, long timeout) void
AbstractMessageChannel.ChannelInterceptorChain.triggerAfterReceiveCompletion
(Message<?> message, MessageChannel channel, ExceptionSE ex) void
AbstractMessageChannel.ChannelInterceptorChain.triggerAfterSendCompletion
(Message<?> message, MessageChannel channel, boolean sent, ExceptionSE ex) 修飾子コンストラクター説明ErrorMessage
(ThrowableSE payload, MapSE<StringSE, ObjectSE> headers, Message<?> originalMessage) 指定されたペイロード、ヘッダー、元のメッセージで新しいメッセージを作成します。ErrorMessage
(ThrowableSE payload, Message<?> originalMessage) 指定されたペイロードと元のメッセージで新しいメッセージを作成します。ErrorMessage
(ThrowableSE payload, MessageHeaders headers, Message<?> originalMessage) ペイロード、MessageHeaders
、元のメッセージを含む新しいメッセージを作成します。MessageHeaderAccessor
(Message<?> message) コピーする既存のメッセージのヘッダーを受け入れるコンストラクター。protected
NativeMessageHeaderAccessor
(Message<?> message) 別のメッセージからヘッダーをコピーする protected コンストラクター。org.springframework.messaging.tcp 内の Message 使用
修飾子と型メソッド説明void
TcpConnectionHandler.handleMessage
(Message<P> message) リモートホストから受信したメッセージを処理します。default ListenableFuture<VoidSE>
非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。指定されたメッセージを送信します。org.springframework.messaging.tcp.reactor 内の Message 使用
修飾子と型メソッド説明AbstractNioBufferReactorNettyCodec.decode
(io.netty.buffer.ByteBuf inputBuffer) ReactorNettyCodec.decode
(io.netty.buffer.ByteBuf inputBuffer) 入力ByteBuf
を 1 つ以上のMessages
にデコードします。TcpMessageCodec.decode
(ByteBufferSE buffer) 入力ByteBuffer
SE を 1 つ以上のMessages
にデコードします。AbstractNioBufferReactorNettyCodec.decodeInternal
(ByteBufferSE nioBuffer) 修飾子と型メソッド説明void
void
指定されたMessage
を出力ByteBuf
にエンコードします。指定されたMessage
を出力ByteBuffer
SE にエンコードします。protected abstract ByteBufferSE
AbstractNioBufferReactorNettyCodec.encodeInternal
(Message<P> message) org.springframework.web.socket.messaging 内の Message 使用
修飾子と型メソッド説明Message<byte[]>
AbstractSubProtocolEvent.getMessage()
イベントに関連付けられたメッセージを返します。Message<byte[]>
StompSubProtocolErrorHandler.handleClientMessageProcessingError
(Message<byte[]> clientMessage, ThrowableSE ex) SubProtocolErrorHandler.handleClientMessageProcessingError
(Message<P> clientMessage, ThrowableSE ex) クライアントメッセージの処理中にスローされたエラーを処理して、エラーメッセージを準備したり、送信されないようにすることができます。Message<byte[]>
StompSubProtocolErrorHandler.handleErrorMessageToClient
(Message<byte[]> errorMessage) SubProtocolErrorHandler.handleErrorMessageToClient
(Message<P> errorMessage) サーバー側からクライアントに送信されたエラーを処理します。たとえば、接続が失敗したため、外部ブローカーがエラーメッセージを送信したために"broke relay"
から発生したエラーなどです。protected Message<byte[]>
StompSubProtocolErrorHandler.handleInternal
(StompHeaderAccessor errorHeaderAccessor, byte[] errorPayload, ThrowableSE cause, StompHeaderAccessor clientHeaderAccessor) 修飾子と型メソッド説明Message<byte[]>
StompSubProtocolErrorHandler.handleClientMessageProcessingError
(Message<byte[]> clientMessage, ThrowableSE ex) SubProtocolErrorHandler.handleClientMessageProcessingError
(Message<P> clientMessage, ThrowableSE ex) クライアントメッセージの処理中にスローされたエラーを処理して、エラーメッセージを準備したり、送信されないようにすることができます。Message<byte[]>
StompSubProtocolErrorHandler.handleErrorMessageToClient
(Message<byte[]> errorMessage) SubProtocolErrorHandler.handleErrorMessageToClient
(Message<P> errorMessage) サーバー側からクライアントに送信されたエラーを処理します。たとえば、接続が失敗したため、外部ブローカーがエラーメッセージを送信したために"broke relay"
から発生したエラーなどです。void
SubProtocolWebSocketHandler.handleMessage
(Message<?> message) WebSocket クライアントへの発信 Spring メッセージを処理します。void
StompSubProtocolHandler.handleMessageToClient
(WebSocketSession session, Message<?> message) WebSocket クライアントに戻る STOMP メッセージを処理します。void
SubProtocolHandler.handleMessageToClient
(WebSocketSession session, Message<?> message) 指定された WebSocket セッションに関連付けられたクライアントに対して、指定されたMessage
を処理します。StompSubProtocolHandler.resolveSessionId
(Message<?> message) SubProtocolHandler.resolveSessionId
(Message<?> message) 指定されたメッセージからセッション ID を解決するか、null
を返します。protected StompHeaderAccessor
StompSubProtocolHandler.toMutableAccessor
(StompHeaderAccessor headerAccessor, Message<?> message) 修飾子コンストラクター説明protected
AbstractSubProtocolEvent
(ObjectSE source, Message<byte[]> message) 新しい AbstractSubProtocolEvent を作成します。protected
AbstractSubProtocolEvent
(ObjectSE source, Message<byte[]> message, PrincipalSE user) 新しい AbstractSubProtocolEvent を作成します。SessionConnectedEvent
(ObjectSE source, Message<byte[]> message) 新しい SessionConnectedEvent を作成します。SessionConnectedEvent
(ObjectSE source, Message<byte[]> message, PrincipalSE user) SessionConnectEvent
(ObjectSE source, Message<byte[]> message) 新しい SessionConnectEvent を作成します。SessionConnectEvent
(ObjectSE source, Message<byte[]> message, PrincipalSE user) SessionDisconnectEvent
(ObjectSE source, Message<byte[]> message, StringSE sessionId, CloseStatus closeStatus) 新しい SessionDisconnectEvent を作成します。SessionDisconnectEvent
(ObjectSE source, Message<byte[]> message, StringSE sessionId, CloseStatus closeStatus, PrincipalSE user) 新しい SessionDisconnectEvent を作成します。SessionSubscribeEvent
(ObjectSE source, Message<byte[]> message) SessionSubscribeEvent
(ObjectSE source, Message<byte[]> message, PrincipalSE user) SessionUnsubscribeEvent
(ObjectSE source, Message<byte[]> message) SessionUnsubscribeEvent
(ObjectSE source, Message<byte[]> message, PrincipalSE user)
TcpConnection.sendAsync(Message)
を推奨