接口 DestinationResolvingMessageRequestReplyOperations<D>

    • 方法详细资料

      • sendAndReceive

        Message<?> sendAndReceive​(String destinationName,
                                  Message<?> requestMessage)
                           throws MessagingException
        Resolve the given destination name to a destination and send the given message, receive a reply and return it.
        参数:
        destinationName - the name of the target destination
        requestMessage - the mesage to send
        返回:
        the received message, possibly null if the message could not be received, for example due to a timeout
        抛出:
        MessagingException
      • convertSendAndReceive

        <T> T convertSendAndReceive​(String destinationName,
                                    Object request,
                                    Class<T> targetClass)
                             throws MessagingException
        Resolve the given destination name, convert the payload request Object to serialized form, possibly using a MessageConverter, wrap it as a message and send it to the resolved destination, receive a reply and convert its body to the specified target class.
        参数:
        destinationName - the name of the target destination
        request - the payload for the request message to send
        targetClass - the target class to convert the payload of the reply to
        返回:
        the converted payload of the reply message, possibly null if the message could not be received, for example due to a timeout
        抛出:
        MessagingException
      • convertSendAndReceive

        <T> T convertSendAndReceive​(String destinationName,
                                    Object request,
                                    Map<String,​Object> headers,
                                    Class<T> targetClass)
                             throws MessagingException
        Resolve the given destination name, convert the payload request Object to serialized form, possibly using a MessageConverter, wrap it as a message with the given headers and send it to the resolved destination, receive a reply and convert its body to the specified target class.
        参数:
        destinationName - the name of the target destination
        request - the payload for the request message to send
        headers - the headers for the request message to send
        targetClass - the target class to convert the payload of the reply to
        返回:
        the converted payload of the reply message, possibly null if the message could not be received, for example due to a timeout
        抛出:
        MessagingException
      • convertSendAndReceive

        <T> T convertSendAndReceive​(String destinationName,
                                    Object request,
                                    Class<T> targetClass,
                                    MessagePostProcessor requestPostProcessor)
                             throws MessagingException
        Resolve the given destination name, convert the payload request Object to serialized form, possibly using a MessageConverter, wrap it as a message, apply the given post process, and send the resulting message to the resolved destination, then receive a reply and convert its body to the specified target class.
        参数:
        destinationName - the name of the target destination
        request - the payload for the request message to send
        targetClass - the target class to convert the payload of the reply to
        requestPostProcessor - post process for the request message
        返回:
        the converted payload of the reply message, possibly null if the message could not be received, for example due to a timeout
        抛出:
        MessagingException
      • convertSendAndReceive

        <T> T convertSendAndReceive​(String destinationName,
                                    Object request,
                                    Map<String,​Object> headers,
                                    Class<T> targetClass,
                                    MessagePostProcessor requestPostProcessor)
                             throws MessagingException
        Resolve the given destination name, convert the payload request Object to serialized form, possibly using a MessageConverter, wrap it as a message with the given headers, apply the given post process, and send the resulting message to the resolved destination, then receive a reply and convert its body to the specified target class.
        参数:
        destinationName - the name of the target destination
        request - the payload for the request message to send
        headers - the headers for the request message to send
        targetClass - the target class to convert the payload of the reply to
        requestPostProcessor - post process for the request message
        返回:
        the converted payload of the reply message, possibly null if the message could not be received, for example due to a timeout
        抛出:
        MessagingException