Interface AmqpClient

public interface AmqpClient

The fluent API for the AMQP 1.0 client.

Since:

4.1

Author:

Artem Bilan

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	AmqpClient.Builder
static interface	AmqpClient.ReceiveSpec	The fluent API for the receiving operation based on the from address.
static interface	AmqpClient.SendSpec	The fluent API for the send operation based on the message building blocks starting with to address.

Method Summary

Modifier and Type	Method	Description
static AmqpClient.Builder	builder(AmqpConnectionFactory connectionFactory)
static AmqpClient	create(AmqpConnectionFactory connectionFactory)
AmqpClient.ReceiveSpec	from(String fromAddress)	The fluent API for the receiving operation based on the from address.
CompletableFuture<Boolean>	send(org.apache.qpid.protonj2.client.Message<?> protonMessage)	Send a ProtonJ message instance.
CompletableFuture<Boolean>	sendToDefault(Message message)	Send a Spring AMQP message.
AmqpClient.SendSpec	to(String toAddress)	The fluent API for the send operation based on the message building blocks starting with to address.

Method Details

send

CompletableFuture<Boolean> send(org.apache.qpid.protonj2.client.Message<?> protonMessage)

Send a ProtonJ message instance. The Message.to() can be omitted if AmqpClient.Builder.defaultToAddress(String) is provided.

Parameters:

protonMessage - the message to send.

Returns:

message settlement result.

sendToDefault

CompletableFuture<Boolean> sendToDefault(Message message)

Send a Spring AMQP message. Converted internally to a ProtonJ message instance. This is a convenient API based on the AmqpClient.Builder.defaultToAddress(String)

Parameters:

message - the message to send.

Returns:

message settlement result.

to

AmqpClient.SendSpec to(String toAddress)

The fluent API for the send operation based on the message building blocks starting with to address.

Parameters:

toAddress - the target AMQP 1.0 address.

Returns:

the AmqpClient.SendSpec with the message building blocks.

from

AmqpClient.ReceiveSpec from(String fromAddress)

The fluent API for the receiving operation based on the from address.

Parameters:

fromAddress - the source AMQP 1.0 address.

Returns:

the AmqpClient.ReceiveSpec.

create

static AmqpClient create(AmqpConnectionFactory connectionFactory)

builder

static AmqpClient.Builder builder(AmqpConnectionFactory connectionFactory)