Package org.springframework.amqp.core

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.