Skip to content

Commit f50eb74

Browse files
committed
Update RPC document to reflect use of direct reply-to
1 parent 7827819 commit f50eb74

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

src/docs/asciidoc/usage.adoc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -235,7 +235,7 @@ This behavior is hardcoded but it is possible to cancel it thanks to a reply pos
235235

236236
The RPC client uses the following defaults:
237237

238-
* it creates and waits for replies on an auto-delete, exclusive queue if no reply-to queue is set.
238+
* it uses https://www.rabbitmq.com/docs/direct-reply-to[direct reply-to] if available (RabbitMQ 4.2 or more) for replies if no reply-to queue is set (it falls back an auto-delete, exclusive queue if direct reply-to is not available)
239239
* it uses a string-based correlation ID generator, with a fixed random UUID prefix and a strictly monotonic increasing sequence suffix (`{UUID}-{sequence}`, e.g. `6f839461-6b19-47e1-80b3-6be10d899d85-42`).
240240
The prefix is different for each `RpcClient` instance and the suffix is incremented by one for each request.
241241
* it sets the _request_ https://docs.oasis-open.org/amqp/core/v1.0/os/amqp-core-messaging-v1.0-os.html#type-properties[`reply-to` property] to the reply-to queue address (defined by the user or created automatically, see above).

src/main/java/com/rabbitmq/client/amqp/Publisher.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ public interface Publisher extends AutoCloseable, Resource {
3232
/**
3333
* Create a message meant to be published by the publisher instance.
3434
*
35-
* <p>Once published with the {@link #publish(Message, Callback)} the message instance should be
35+
* <p>Once published with the {@link #publish(Message, Callback)} the message instance should
3636
* not be modified or even reused.
3737
*
3838
* @return a message
@@ -42,7 +42,7 @@ public interface Publisher extends AutoCloseable, Resource {
4242
/**
4343
* Create a message meant to be published by the publisher instance.
4444
*
45-
* <p>Once published with the {@link #publish(Message, Callback)} the message instance should be
45+
* <p>Once published with the {@link #publish(Message, Callback)} the message instance should
4646
* not be modified or even reused.
4747
*
4848
* @param body message body

src/main/java/com/rabbitmq/client/amqp/RpcClient.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ public interface RpcClient extends AutoCloseable {
2929
/**
3030
* Create a message meant to be published by the underlying publisher instance.
3131
*
32-
* <p>Once published with the {@link #publish(Message)} the message instance should be not be
32+
* <p>Once published with the {@link #publish(Message)} the message instance should not be
3333
* modified or even reused.
3434
*
3535
* @return a message
@@ -39,7 +39,7 @@ public interface RpcClient extends AutoCloseable {
3939
/**
4040
* Create a message meant to be published by the underlying publisher instance.
4141
*
42-
* <p>Once published with the {@link #publish(Message)} the message instance should be not be
42+
* <p>Once published with the {@link #publish(Message)} the message instance should not be
4343
* modified or even reused.
4444
*
4545
* @param body message body

0 commit comments

Comments
 (0)