インターフェースの使用
org.springframework.messaging.Message
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 使用
Message を返す org.springframework.jms.core のメソッド修飾子と型メソッド説明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) 型 Message のパラメーターを持つ org.springframework.jms.core のメソッド修飾子と型メソッド説明protected voidJmsMessagingTemplate.doSend(DestinationEE destination, Message<?> message) protected voidprotected Message<?>JmsMessagingTemplate.doSendAndReceive(DestinationEE destination, Message<?> requestMessage) protected Message<?>JmsMessagingTemplate.doSendAndReceive(StringSE destinationName, Message<?> requestMessage) void指定された宛先にメッセージを送信します。voidvoidMessage<?>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 使用
型 Message のパラメーターを持つ org.springframework.jms.support のメソッド型 Message のパラメーターを持つ org.springframework.jms.support のコンストラクターorg.springframework.messaging 内の Message 使用
Message を返す org.springframework.messaging のメソッド修飾子と型メソッド説明Message<?>MessagingException.getFailedMessage()Message<?>PollableChannel.receive()このチャネルからメッセージを受信し、必要に応じて無期限にブロックします。Message<?>PollableChannel.receive(long timeout) このチャネルからメッセージを受信し、メッセージが利用可能になるか、指定されたタイムアウト期間が経過するまでブロックします。型 Message のパラメーターを持つ org.springframework.messaging のメソッド修飾子と型メソッド説明voidMessageHandler.handleMessage(Message<?> message) 指定されたメッセージを処理します。reactor.core.publisher.Mono<VoidSE>ReactiveMessageHandler.handleMessage(Message<?> message) 指定されたメッセージを処理します。default booleanMessageをこのチャネルに送信します。booleanメッセージを送信し、メッセージが受け入れられるか、指定されたタイムアウト期間が経過するまでブロックします。型 Message のパラメーターを持つ org.springframework.messaging のコンストラクター修飾子コンストラクター説明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)のバリアントで、追加の変換コンテキストを引数として受け取り、たとえば戻り値の型のアノテーションを考慮に入れることができます。型 Message のパラメーターを持つ org.springframework.messaging.converter のメソッド修飾子と型メソッド説明protected booleanAbstractMessageConverter.canConvertFrom(Message<?> message, ClassSE<?> targetClass) protected booleanMappingJackson2MessageConverter.canConvertFrom(Message<?> message, ClassSE<?> targetClass) protected booleanMarshallingMessageConverter.canConvertFrom(Message<?> message, ClassSE<?> targetClass) protected ObjectSEAbstractJsonMessageConverter.convertFromInternal(Message<?> message, ClassSE<?> targetClass, ObjectSE conversionHint) protected ObjectSEAbstractMessageConverter.convertFromInternal(Message<?> message, ClassSE<?> targetClass, ObjectSE conversionHint) メッセージペイロードを直列化された形式からオブジェクトに変換します。protected ObjectSEByteArrayMessageConverter.convertFromInternal(Message<?> message, ClassSE<?> targetClass, ObjectSE conversionHint) protected ObjectSEMappingJackson2MessageConverter.convertFromInternal(Message<?> message, ClassSE<?> targetClass, ObjectSE conversionHint) protected ObjectSEMarshallingMessageConverter.convertFromInternal(Message<?> message, ClassSE<?> targetClass, ObjectSE conversionHint) protected ObjectSEProtobufMessageConverter.convertFromInternal(Message<?> message, ClassSE<?> targetClass, ObjectSE conversionHint) protected ObjectSEStringMessageConverter.convertFromInternal(Message<?> message, ClassSE<?> targetClass, ObjectSE conversionHint) final ObjectSEAbstractMessageConverter.fromMessage(Message<?> message, ClassSE<?> targetClass) final ObjectSEAbstractMessageConverter.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)のバリアントで、追加の変換コンテキストを引数として受け取り、たとえばペイロードパラメーターのアノテーションを考慮に入れることができます。型 Message のパラメーターを持つ org.springframework.messaging.converter のコンストラクター修飾子コンストラクター説明MessageConversionException(Message<?> failedMessage, StringSE description) MessageConversionException(Message<?> failedMessage, StringSE description, ThrowableSE cause) org.springframework.messaging.core 内の Message 使用
Message を返す org.springframework.messaging.core のメソッド修飾子と型メソッド説明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) リクエストメッセージを送信し、デフォルトの宛先から応答を受信します。型 Message のパラメーターを持つ org.springframework.messaging.core のメソッド修飾子と型メソッド説明protected <T> T指定されたメッセージから指定されたターゲットクラスに変換します。protected abstract voidprotected final voidGenericMessagingTemplate.doSend(MessageChannel channel, Message<?> message) protected final voidGenericMessagingTemplate.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) 指定されたメッセージを処理します。voidvoidvoidvoid指定された宛先名を宛先に解決し、メッセージを送信します。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 使用
型 Message のパラメーターを持つ org.springframework.messaging.handler のメソッド修飾子と型メソッド説明intCompositeMessageCondition.compareTo(CompositeMessageCondition other, Message<?> message) intDestinationPatternsMessageCondition.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 使用
型 Message のパラメーターを持つ org.springframework.messaging.handler.annotation.reactive のメソッド修飾子と型メソッド説明protected RouteMatcher.RouteMessageMappingMessageHandler.getDestination(Message<?> message) protected ComparatorSE<CompositeMessageCondition>MessageMappingMessageHandler.getMappingComparator(Message<?> message) protected CompositeMessageConditionMessageMappingMessageHandler.getMatchingMapping(CompositeMessageCondition mapping, Message<?> message) protected MimeTypePayloadMethodArgumentResolver.getMimeType(Message<?> message) コンテンツの MIME 型を返します。protected reactor.core.publisher.Mono<VoidSE>MessageMappingMessageHandler.handleMatch(CompositeMessageCondition mapping, HandlerMethod handlerMethod, Message<?> message) protected abstract voidAbstractNamedValueMethodArgumentResolver.handleMissingValue(StringSE name, MethodParameter parameter, Message<?> message) 値が必要なときに呼び出されますが、AbstractNamedValueMethodArgumentResolver.resolveArgumentInternal(org.springframework.core.MethodParameter, org.springframework.messaging.Message<?>, java.lang.String)はnullを返し、デフォルト値はありません。protected voidDestinationVariableMethodArgumentResolver.handleMissingValue(StringSE name, MethodParameter parameter, Message<?> message) protected voidHeaderMethodArgumentResolver.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 ObjectSEAbstractNamedValueMethodArgumentResolver.resolveArgumentInternal(MethodParameter parameter, Message<?> message, StringSE name) 指定されたパラメーターの型と値の名前を引数値に解決します。protected ObjectSEDestinationVariableMethodArgumentResolver.resolveArgumentInternal(MethodParameter parameter, Message<?> message, StringSE name) protected ObjectSEHeaderMethodArgumentResolver.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 使用
型 Message のパラメーターを持つ org.springframework.messaging.handler.annotation.support のメソッド修飾子と型メソッド説明protected ClassSE<?>MessageMethodArgumentResolver.getPayloadType(MethodParameter parameter, Message<?> message) ペイロードを変換するターゲットクラスを解決します。protected abstract voidAbstractNamedValueMethodArgumentResolver.handleMissingValue(StringSE name, MethodParameter parameter, Message<?> message) 値が必要なときに呼び出されますが、AbstractNamedValueMethodArgumentResolver.resolveArgumentInternal(org.springframework.core.MethodParameter, org.springframework.messaging.Message<?>, java.lang.String)はnullを返し、デフォルト値はありません。protected voidDestinationVariableMethodArgumentResolver.handleMissingValue(StringSE name, MethodParameter parameter, Message<?> message) protected voidHeaderMethodArgumentResolver.handleMissingValue(StringSE headerName, MethodParameter parameter, Message<?> message) protected voidAbstractNamedValueMethodArgumentResolver.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 ObjectSEAbstractNamedValueMethodArgumentResolver.resolveArgumentInternal(MethodParameter parameter, Message<?> message, StringSE name) 指定されたパラメーターの型と値の名前を引数値に解決します。protected ObjectSEDestinationVariableMethodArgumentResolver.resolveArgumentInternal(MethodParameter parameter, Message<?> message, StringSE name) protected ObjectSEHeaderMethodArgumentResolver.resolveArgumentInternal(MethodParameter parameter, Message<?> message, StringSE name) protected ClassSE<?>PayloadMethodArgumentResolver.resolveTargetClass(MethodParameter parameter, Message<?> message) ペイロードを変換するターゲットクラスを解決します。protected voidPayloadMethodArgumentResolver.validate(Message<?> message, MethodParameter parameter, ObjectSE target) 該当する場合、ペイロードを検証します。型 Message のパラメーターを持つ org.springframework.messaging.handler.annotation.support のコンストラクター修飾子コンストラクター説明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 使用
型 Message のパラメーターを持つ org.springframework.messaging.handler.invocation のメソッド修飾子と型メソッド説明protected abstract StringSEAbstractMethodMessageHandler.getDestination(Message<?> message) protected abstract ComparatorSE<T>AbstractMethodMessageHandler.getMappingComparator(Message<?> message) 一致するマッピングをソートするためのコンパレーターを返します。protected abstract TAbstractMethodMessageHandler.getMatchingMapping(T mapping, Message<?> message) マッピングが現在のメッセージと一致するかどうかを確認し、現在のリクエストに関連する条件を含む新しいマッピングを返す可能性があります。protected ObjectSE[]InvocableHandlerMethod.getMethodArgumentValues(Message<?> message, ObjectSE... providedArgs) 現在のメッセージのメソッド引数値を取得し、提供された引数値を確認して、構成された引数リゾルバーにフォールバックします。protected voidAbstractMethodMessageHandler.handleMatch(T mapping, HandlerMethod handlerMethod, StringSE lookupDestination, Message<?> message) voidAbstractMethodMessageHandler.handleMessage(Message<?> message) protected voidAbstractMethodMessageHandler.handleMessageInternal(Message<?> message, StringSE lookupDestination) protected voidAbstractMethodMessageHandler.handleNoMatch(SetSE<T> ts, StringSE lookupDestination, Message<?> message) voidAbstractAsyncReturnValueHandler.handleReturnValue(ObjectSE returnValue, MethodParameter returnType, Message<?> message) voidHandlerMethodReturnValueHandler.handleReturnValue(ObjectSE returnValue, MethodParameter returnType, Message<?> message) 指定された戻り値を処理します。voidHandlerMethodReturnValueHandlerComposite.handleReturnValue(ObjectSE returnValue, MethodParameter returnType, Message<?> message) 指定されたメッセージのコンテキストで引数値を解決した後、メソッドを呼び出します。protected voidAbstractMethodMessageHandler.processHandlerMethodException(HandlerMethod handlerMethod, ExceptionSE exception, Message<?> message) HandlerMethodArgumentResolver.resolveArgument(MethodParameter parameter, Message<?> message) メソッドパラメーターを特定のメッセージの引数値に解決します。HandlerMethodArgumentResolverComposite.resolveArgument(MethodParameter parameter, Message<?> message) 登録されたHandlerMethodArgumentResolversを反復処理し、それをサポートするHandlerMethodArgumentResolversを呼び出します。型 Message のパラメーターを持つ org.springframework.messaging.handler.invocation のコンストラクター修飾子コンストラクター説明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 使用
型 Message のパラメーターを持つ org.springframework.messaging.handler.invocation.reactive のメソッド修飾子と型メソッド説明protected abstract RouteMatcher.RouteAbstractMethodMessageHandler.getDestination(Message<?> message) 指定されたメッセージから宛先を抽出します。protected abstract ComparatorSE<T>AbstractMethodMessageHandler.getMappingComparator(Message<?> message) 一致するマッピングをソートするためのコンパレーターを返します。protected abstract TAbstractMethodMessageHandler.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 voidAbstractMethodMessageHandler.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 使用
型 Message のパラメーターを持つ org.springframework.messaging.rsocket.annotation.support のメソッド修飾子と型メソッド説明intRSocketFrameTypeMessageCondition.compareTo(RSocketFrameTypeMessageCondition other, Message<?> message) static io.rsocket.frame.FrameTypeRSocketFrameTypeMessageCondition.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 voidRSocketMessageHandler.handleNoMatch(RouteMatcher.Route destination, Message<?> message) reactor.core.publisher.Mono<ObjectSE>RSocketRequesterMethodArgumentResolver.resolveArgument(MethodParameter parameter, Message<?> message) org.springframework.messaging.simp 内の Message 使用
型 Message のパラメーターを持つ org.springframework.messaging.simp のメソッド修飾子と型メソッド説明intSimpMessageMappingInfo.compareTo(SimpMessageMappingInfo other, Message<?> message) intSimpMessageTypeMessageCondition.compareTo(SimpMessageTypeMessageCondition other, Message<?> message) protected MessageHeaderAccessorSimpMessageHeaderAccessor.createAccessor(Message<?> message) protected voidstatic SimpAttributesSimpAttributes.fromMessage(Message<?> message) 指定されたメッセージから SiMP セッション属性を抽出し、SimpAttributesインスタンスにラップします。SimpMessageMappingInfo.getMatchingCondition(Message<?> message) SimpMessageTypeMessageCondition.getMatchingCondition(Message<?> message) void指定されたメッセージのヘッダーにすでにSimpMessageHeaderAccessor#DESTINATION_HEADERが含まれている場合、メッセージは変更なしで送信されます。static voidSimpAttributesContextHolder.setAttributesFromMessage(Message<?> message) 指定されたメッセージから SiMP セッション属性を抽出し、SimpAttributesインスタンスにラップして、現在のスレッドにバインドします。static SimpMessageHeaderAccessorメッセージのヘッダーをコピーしてインスタンスを作成します。型 Message のパラメーターを持つ org.springframework.messaging.simp のコンストラクター修飾子コンストラクター説明protectedSimpMessageHeaderAccessor(Message<?> message) 既存のメッセージヘッダーにアクセスして変更するためのコンストラクター。org.springframework.messaging.simp.annotation.support 内の Message 使用
型 Message のパラメーターを持つ org.springframework.messaging.simp.annotation.support のメソッド修飾子と型メソッド説明protected StringSESimpAnnotationMethodMessageHandler.getDestination(Message<?> message) protected ComparatorSE<SimpMessageMappingInfo>SimpAnnotationMethodMessageHandler.getMappingComparator(Message<?> message) protected SimpMessageMappingInfoSimpAnnotationMethodMessageHandler.getMatchingMapping(SimpMessageMappingInfo mapping, Message<?> message) protected StringSE[]SendToMethodReturnValueHandler.getTargetDestinations(AnnotationSE annotation, Message<?> message, StringSE defaultPrefix) protected StringSESendToMethodReturnValueHandler.getUserName(Message<?> message, MessageHeaders headers) protected voidSimpAnnotationMethodMessageHandler.handleMatch(SimpMessageMappingInfo mapping, HandlerMethod handlerMethod, StringSE lookupDestination, Message<?> message) voidSendToMethodReturnValueHandler.handleReturnValue(ObjectSE returnValue, MethodParameter returnType, Message<?> message) voidSubscriptionMethodReturnValueHandler.handleReturnValue(ObjectSE returnValue, MethodParameter returnType, Message<?> message) PrincipalMethodArgumentResolver.resolveArgument(MethodParameter parameter, Message<?> message) 型 Message のパラメーターを持つ org.springframework.messaging.simp.annotation.support のコンストラクターorg.springframework.messaging.simp.broker 内の Message 使用
型 Message のパラメーターを持つ org.springframework.messaging.simp.broker のメソッド修飾子と型メソッド説明protected abstract voidAbstractSubscriptionRegistry.addSubscriptionInternal(StringSE sessionId, StringSE subscriptionId, StringSE destination, Message<?> message) protected voidDefaultSubscriptionRegistry.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 RunnableSEOrderedMessageChannelDecorator.getNextMessageTask(Message<?> message) 見つかった場合は、次のメッセージを解放するタスクを取得します。voidAbstractBrokerMessageHandler.handleMessage(Message<?> message) protected abstract voidAbstractBrokerMessageHandler.handleMessageInternal(Message<?> message) protected voidSimpleBrokerMessageHandler.handleMessageInternal(Message<?> message) final voidAbstractSubscriptionRegistry.registerSubscription(Message<?> message) voidSubscriptionRegistry.registerSubscription(Message<?> subscribeMessage) 指定されたメッセージが表すサブスクリプションを登録します。protected abstract voidAbstractSubscriptionRegistry.removeSubscriptionInternal(StringSE sessionId, StringSE subscriptionId, Message<?> message) protected voidDefaultSubscriptionRegistry.removeSubscriptionInternal(StringSE sessionId, StringSE subscriptionId, Message<?> message) booleanbooleanprotected voidSimpleBrokerMessageHandler.sendMessageToSubscribers(StringSE destination, Message<?> message) final voidAbstractSubscriptionRegistry.unregisterSubscription(Message<?> message) voidSubscriptionRegistry.unregisterSubscription(Message<?> unsubscribeMessage) サブスクリプションの登録を解除します。org.springframework.messaging.simp.stomp 内の Message 使用
型 Message の引数を持つ型を返す org.springframework.messaging.simp.stomp のメソッド修飾子と型メソッド説明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) 型 Message のパラメーターを持つ org.springframework.messaging.simp.stomp のメソッド修飾子と型メソッド説明protected MessageHeaderAccessorStompHeaderAccessor.createAccessor(Message<?> message) byte[]指定された STOMPmessageをbyte[]にエンコードします。protected ByteBufferSEStompReactorNettyCodec.encodeInternal(Message<byte[]> message) voidDefaultStompSession.handleMessage(Message<byte[]> message) protected voidStompBrokerRelayMessageHandler.handleMessageInternal(Message<?> message) static StompHeaderAccessor指定されたメッセージのペイロードとヘッダーからインスタンスを作成します。org.springframework.messaging.simp.user 内の Message 使用
型 Message のパラメーターを持つ org.springframework.messaging.simp.user のメソッド修飾子と型メソッド説明voidUserDestinationMessageHandler.handleMessage(Message<?> sourceMessage) voidUserRegistryMessageHandler.handleMessage(Message<?> message) DefaultUserDestinationResolver.resolveDestination(Message<?> message) UserDestinationResolver.resolveDestination(Message<?> message) ユーザー宛先を指定したメッセージを、実際の宛先を含む 1 つ以上のメッセージ(アクティブなユーザーセッションごとに 1 つ)に解決します。org.springframework.messaging.support 内の Message 使用
Message を実装している org.springframework.messaging.support のクラスMessage を返す org.springframework.messaging.support のメソッド修飾子と型メソッド説明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 に送信されたRunnableSE 内で呼び出されます。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) 型 Message のパラメーターを持つ 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) Message<?>AbstractMessageChannel.ChannelInterceptorChain.applyPreSend(Message<?> message, MessageChannel channel) default Message<?>ExecutorChannelInterceptor.beforeHandle(Message<?> message, MessageChannel channel, MessageHandler handler) ターゲット MessageHandler を呼び出してメッセージを処理する直前に、Executor に送信されたRunnableSE 内で呼び出されます。protected MessageHeaderAccessorMessageHeaderAccessor.createAccessor(Message<?> message) 指定されたメッセージの「ネストされた」アクセサーを構築します。static <T> MessageBuilder<T>MessageBuilder.fromMessage(Message<T> message) 提供されたメッセージからコピーされたすべてのヘッダーが事前に入力された新しいMessageインスタンスのビルダーを作成します。static MessageHeaderAccessorMessageHeaderAccessor.getAccessor(Message<?> message) 指定されたMessageのヘッダーの作成に使用された元のMessageHeaderAccessorを返します。または、nullが利用できない場合、またはその型が必要な型と一致しない場合は、nullを返します。static <T extends MessageHeaderAccessor>
TMessageHeaderAccessor.getAccessor(Message<?> message, ClassSE<T> requiredType) 指定されたMessageのヘッダーの作成に使用された元のMessageHeaderAccessorを返します。または、nullが利用できない場合、またはその型が必要な型と一致しない場合は、nullを返します。static MessageHeaderAccessorMessageHeaderAccessor.getMutableAccessor(Message<?> message) メッセージヘッダーを作成するために使用されるアクセサーの型と一致しようとする、またはメッセージをMessageHeaderAccessorインスタンスでラップする、指定されたメッセージの可変MessageHeaderAccessorを返します。default Message<?>ChannelInterceptor.postReceive(Message<?> message, MessageChannel channel) Message が取得された直後、呼び出し元に返される前に呼び出されます。default voidChannelInterceptor.postSend(Message<?> message, MessageChannel channel, boolean sent) 送信呼び出しの直後に呼び出されます。default Message<?>ChannelInterceptor.preSend(Message<?> message, MessageChannel channel) メッセージが実際にチャネルに送信される前に呼び出されます。Message<?>ImmutableMessageChannelInterceptor.preSend(Message<?> message, MessageChannel channel) final booleanfinal booleanprotected abstract booleanAbstractMessageChannel.sendInternal(Message<?> message, long timeout) booleanExecutorSubscribableChannel.sendInternal(Message<?> message, long timeout) voidAbstractMessageChannel.ChannelInterceptorChain.triggerAfterReceiveCompletion(Message<?> message, MessageChannel channel, ExceptionSE ex) voidAbstractMessageChannel.ChannelInterceptorChain.triggerAfterSendCompletion(Message<?> message, MessageChannel channel, boolean sent, ExceptionSE ex) 型 Message のパラメーターを持つ org.springframework.messaging.support のコンストラクター修飾子コンストラクター説明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) コピーする既存のメッセージのヘッダーを受け入れるコンストラクター。protectedNativeMessageHeaderAccessor(Message<?> message) 別のメッセージからヘッダーをコピーする protected コンストラクター。org.springframework.messaging.tcp 内の Message 使用
型 Message のパラメーターを持つ org.springframework.messaging.tcp のメソッド修飾子と型メソッド説明voidTcpConnectionHandler.handleMessage(Message<P> message) リモートホストから受信したメッセージを処理します。default ListenableFuture<VoidSE>非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。指定されたメッセージを送信します。org.springframework.messaging.tcp.reactor 内の Message 使用
型 Message の引数を持つ型を返す org.springframework.messaging.tcp.reactor のメソッド修飾子と型メソッド説明AbstractNioBufferReactorNettyCodec.decode(io.netty.buffer.ByteBuf inputBuffer) ReactorNettyCodec.decode(io.netty.buffer.ByteBuf inputBuffer) 入力ByteBufを 1 つ以上のMessagesにデコードします。TcpMessageCodec.decode(ByteBufferSE buffer) 入力ByteBufferSE を 1 つ以上のMessagesにデコードします。AbstractNioBufferReactorNettyCodec.decodeInternal(ByteBufferSE nioBuffer) 型 Message のパラメーターを持つ org.springframework.messaging.tcp.reactor のメソッド修飾子と型メソッド説明voidvoid指定されたMessageを出力ByteBufにエンコードします。指定されたMessageを出力ByteBufferSE にエンコードします。protected abstract ByteBufferSEAbstractNioBufferReactorNettyCodec.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 のパラメーターを持つ org.springframework.web.socket.messaging のメソッド修飾子と型メソッド説明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"から発生したエラーなどです。voidSubProtocolWebSocketHandler.handleMessage(Message<?> message) WebSocket クライアントへの発信 Spring メッセージを処理します。voidStompSubProtocolHandler.handleMessageToClient(WebSocketSession session, Message<?> message) WebSocket クライアントに戻る STOMP メッセージを処理します。voidSubProtocolHandler.handleMessageToClient(WebSocketSession session, Message<?> message) 指定された WebSocket セッションに関連付けられたクライアントに対して、指定されたMessageを処理します。StompSubProtocolHandler.resolveSessionId(Message<?> message) SubProtocolHandler.resolveSessionId(Message<?> message) 指定されたメッセージからセッション ID を解決するか、nullを返します。protected StompHeaderAccessorStompSubProtocolHandler.toMutableAccessor(StompHeaderAccessor headerAccessor, Message<?> message) 型 Message のパラメーターを持つ org.springframework.web.socket.messaging のコンストラクター修飾子コンストラクター説明protectedAbstractSubProtocolEvent(ObjectSE source, Message<byte[]> message) 新しい AbstractSubProtocolEvent を作成します。protectedAbstractSubProtocolEvent(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)を推奨