Class AmqpClient.Builder
java.lang.Object
org.springframework.amqp.client.AmqpClient.Builder
- Enclosing interface:
AmqpClient
- Since:
- 4.1
- Author:
- Artem Bilan
-
Method Summary
Modifier and TypeMethodDescriptionbuild()Build theAmqpClientinstance based on the provided options.completionTimeout(Duration completionTimeout) Set a duration forCompletableFuture.orTimeout(long, TimeUnit)on returns.defaultToAddress(String defaultToAddress) Set the default target AMQP 1.0 address for theAmqpClient.sendToDefault(org.springframework.amqp.core.Message)andAmqpClient.send(Message)operations.messageConverter(MessageConverter messageConverter) Set theMessageConverterfor converting to/from message body.senderOptions(org.apache.qpid.protonj2.client.SenderOptions senderOptions) Set theSenderOptionsfor an internal AMQP 1.0Sender.taskExecutor(TaskExecutor taskExecutor) Set theTaskExecutorfor asynchronous operations.
-
Method Details
-
senderOptions
public AmqpClient.Builder senderOptions(org.apache.qpid.protonj2.client.SenderOptions senderOptions) Set theSenderOptionsfor an internal AMQP 1.0Sender.- Parameters:
senderOptions- to use.- Returns:
- this builder.
-
completionTimeout
Set a duration forCompletableFuture.orTimeout(long, TimeUnit)on returns. There is noCompletableFutureAPI likeonTimeout()requested from theCompletableFuture.get(long, TimeUnit), but used in operations AMQP resources have to be closed eventually independently of theCompletableFuturefulfilment. Defaults to 1 minute.- Parameters:
completionTimeout- duration for future completions.- Returns:
- this builder.
-
defaultToAddress
Set the default target AMQP 1.0 address for theAmqpClient.sendToDefault(org.springframework.amqp.core.Message)andAmqpClient.send(Message)operations.- Parameters:
defaultToAddress- the target address to use as a convenient default.- Returns:
- this builder.
-
messageConverter
Set theMessageConverterfor converting to/from message body. For theAmqpClient.ReceiveSpec.receiveAndConvert(T...)with non-Objectgeneric type, this converter has to beSmartMessageConverter.- Parameters:
messageConverter- the converter.- Returns:
- this builder.
-
taskExecutor
Set theTaskExecutorfor asynchronous operations. AThreadPoolExecutorwith one core pool thread is used by default.- Parameters:
taskExecutor- the task executor.- Returns:
- this builder.
-
build
Build theAmqpClientinstance based on the provided options.- Returns:
- the client instance.
-