Interface AmqpClient
public interface AmqpClient
The fluent API for the AMQP 1.0 client.
- Since:
- 4.1
- Author:
- Artem Bilan
-
Nested Class Summary
Nested ClassesModifier and TypeInterfaceDescriptionstatic classstatic interfaceThe fluent API for the receiving operation based on thefromaddress.static interfaceThe fluent API for the send operation based on the message building blocks starting withtoaddress. -
Method Summary
Modifier and TypeMethodDescriptionstatic AmqpClient.Builderbuilder(AmqpConnectionFactory connectionFactory) static AmqpClientcreate(AmqpConnectionFactory connectionFactory) The fluent API for the receiving operation based on thefromaddress.send(org.apache.qpid.protonj2.client.Message<?> protonMessage) Send a ProtonJ message instance.sendToDefault(Message message) Send a Spring AMQP message.The fluent API for the send operation based on the message building blocks starting withtoaddress.
-
Method Details
-
send
Send a ProtonJ message instance. TheMessage.to()can be omitted ifAmqpClient.Builder.defaultToAddress(String)is provided.- Parameters:
protonMessage- the message to send.- Returns:
- message settlement result.
-
sendToDefault
Send a Spring AMQP message. Converted internally to a ProtonJ message instance. This is a convenient API based on theAmqpClient.Builder.defaultToAddress(String)- Parameters:
message- the message to send.- Returns:
- message settlement result.
-
to
The fluent API for the send operation based on the message building blocks starting withtoaddress.- Parameters:
toAddress- the target AMQP 1.0 address.- Returns:
- the
AmqpClient.SendSpecwith the message building blocks.
-
from
The fluent API for the receiving operation based on thefromaddress.- Parameters:
fromAddress- the source AMQP 1.0 address.- Returns:
- the
AmqpClient.ReceiveSpec.
-
create
-
builder
-