Interface AsyncAmqpTemplate

  • All Known Implementing Classes:
    AsyncRabbitTemplate

    public interface AsyncAmqpTemplate
    Classes implementing this interface can perform asynchronous send and receive operations.
    Since:
    2.0
    Author:
    Gary Russell
    • Method Detail

      • sendAndReceive

        ListenableFuture<Message> sendAndReceive​(Message message)
        Send a message to the default exchange with the default routing key. If the message contains a correlationId property, it must be unique.
        Parameters:
        message - the message.
        Returns:
        the ListenableFuture.
      • sendAndReceive

        ListenableFuture<Message> sendAndReceive​(String routingKey,
                                                 Message message)
        Send a message to the default exchange with the supplied routing key. If the message contains a correlationId property, it must be unique.
        Parameters:
        routingKey - the routing key.
        message - the message.
        Returns:
        the ListenableFuture.
      • sendAndReceive

        ListenableFuture<Message> sendAndReceive​(String exchange,
                                                 String routingKey,
                                                 Message message)
        Send a message to the supplied exchange and routing key. If the message contains a correlationId property, it must be unique.
        Parameters:
        exchange - the exchange.
        routingKey - the routing key.
        message - the message.
        Returns:
        the ListenableFuture.
      • convertSendAndReceive

        <C> ListenableFuture<C> convertSendAndReceive​(Object object)
        Convert the object to a message and send it to the default exchange with the default routing key.
        Type Parameters:
        C - the expected result type.
        Parameters:
        object - the object to convert.
        Returns:
        the ListenableFuture.
      • convertSendAndReceive

        <C> ListenableFuture<C> convertSendAndReceive​(String routingKey,
                                                      Object object)
        Convert the object to a message and send it to the default exchange with the provided routing key.
        Type Parameters:
        C - the expected result type.
        Parameters:
        routingKey - the routing key.
        object - the object to convert.
        Returns:
        the ListenableFuture.
      • convertSendAndReceive

        <C> ListenableFuture<C> convertSendAndReceive​(String exchange,
                                                      String routingKey,
                                                      Object object)
        Convert the object to a message and send it to the provided exchange and routing key.
        Type Parameters:
        C - the expected result type.
        Parameters:
        exchange - the exchange.
        routingKey - the routing key.
        object - the object to convert.
        Returns:
        the ListenableFuture.
      • convertSendAndReceive

        <C> ListenableFuture<C> convertSendAndReceive​(Object object,
                                                      MessagePostProcessor messagePostProcessor)
        Convert the object to a message and send it to the default exchange with the default routing key after invoking the MessagePostProcessor. If the post processor adds a correlationId property, it must be unique.
        Type Parameters:
        C - the expected result type.
        Parameters:
        object - the object to convert.
        messagePostProcessor - the post processor.
        Returns:
        the ListenableFuture.
      • convertSendAndReceive

        <C> ListenableFuture<C> convertSendAndReceive​(String routingKey,
                                                      Object object,
                                                      MessagePostProcessor messagePostProcessor)
        Convert the object to a message and send it to the default exchange with the provided routing key after invoking the MessagePostProcessor. If the post processor adds a correlationId property, it must be unique.
        Type Parameters:
        C - the expected result type.
        Parameters:
        routingKey - the routing key.
        object - the object to convert.
        messagePostProcessor - the post processor.
        Returns:
        the ListenableFuture.
      • convertSendAndReceive

        <C> ListenableFuture<C> convertSendAndReceive​(String exchange,
                                                      String routingKey,
                                                      Object object,
                                                      MessagePostProcessor messagePostProcessor)
        Convert the object to a message and send it to the provided exchange and routing key after invoking the MessagePostProcessor. If the post processor adds a correlationId property, it must be unique.
        Type Parameters:
        C - the expected result type.
        Parameters:
        exchange - the exchange
        routingKey - the routing key.
        object - the object to convert.
        messagePostProcessor - the post processor.
        Returns:
        the ListenableFuture.
      • convertSendAndReceiveAsType

        <C> ListenableFuture<C> convertSendAndReceiveAsType​(Object object,
                                                            ParameterizedTypeReference<C> responseType)
        Convert the object to a message and send it to the default exchange with the default routing key.
        Type Parameters:
        C - the expected result type.
        Parameters:
        object - the object to convert.
        responseType - the response type.
        Returns:
        the ListenableFuture.
      • convertSendAndReceiveAsType

        <C> ListenableFuture<C> convertSendAndReceiveAsType​(String routingKey,
                                                            Object object,
                                                            ParameterizedTypeReference<C> responseType)
        Convert the object to a message and send it to the default exchange with the provided routing key.
        Type Parameters:
        C - the expected result type.
        Parameters:
        routingKey - the routing key.
        object - the object to convert.
        responseType - the response type.
        Returns:
        the ListenableFuture.
      • convertSendAndReceiveAsType

        <C> ListenableFuture<C> convertSendAndReceiveAsType​(String exchange,
                                                            String routingKey,
                                                            Object object,
                                                            ParameterizedTypeReference<C> responseType)
        Convert the object to a message and send it to the provided exchange and routing key.
        Type Parameters:
        C - the expected result type.
        Parameters:
        exchange - the exchange.
        routingKey - the routing key.
        object - the object to convert.
        responseType - the response type.
        Returns:
        the ListenableFuture.
      • convertSendAndReceiveAsType

        <C> ListenableFuture<C> convertSendAndReceiveAsType​(Object object,
                                                            MessagePostProcessor messagePostProcessor,
                                                            ParameterizedTypeReference<C> responseType)
        Convert the object to a message and send it to the default exchange with the default routing key after invoking the MessagePostProcessor. If the post processor adds a correlationId property, it must be unique.
        Type Parameters:
        C - the expected result type.
        Parameters:
        object - the object to convert.
        messagePostProcessor - the post processor.
        responseType - the response type.
        Returns:
        the ListenableFuture.
      • convertSendAndReceiveAsType

        <C> ListenableFuture<C> convertSendAndReceiveAsType​(String routingKey,
                                                            Object object,
                                                            MessagePostProcessor messagePostProcessor,
                                                            ParameterizedTypeReference<C> responseType)
        Convert the object to a message and send it to the default exchange with the provided routing key after invoking the MessagePostProcessor. If the post processor adds a correlationId property, it must be unique.
        Type Parameters:
        C - the expected result type.
        Parameters:
        routingKey - the routing key.
        object - the object to convert.
        messagePostProcessor - the post processor.
        responseType - the response type.
        Returns:
        the ListenableFuture.
      • convertSendAndReceiveAsType

        <C> ListenableFuture<C> convertSendAndReceiveAsType​(String exchange,
                                                            String routingKey,
                                                            Object object,
                                                            MessagePostProcessor messagePostProcessor,
                                                            ParameterizedTypeReference<C> responseType)
        Convert the object to a message and send it to the provided exchange and routing key after invoking the MessagePostProcessor. If the post processor adds a correlationId property, it must be unique.
        Type Parameters:
        C - the expected result type.
        Parameters:
        exchange - the exchange
        routingKey - the routing key.
        object - the object to convert.
        messagePostProcessor - the post processor.
        responseType - the response type.
        Returns:
        the ListenableFuture.