Skip to content

Commit 3a0056a

Browse files
committed
Improve deduplication Javadoc
1 parent 3784060 commit 3a0056a

File tree

3 files changed

+25
-7
lines changed

3 files changed

+25
-7
lines changed

src/main/java/com/rabbitmq/stream/Message.java

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
// Copyright (c) 2020-2023 Broadcom. All Rights Reserved.
1+
// Copyright (c) 2020-2024 Broadcom. All Rights Reserved.
22
// The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
33
//
44
// This software, the RabbitMQ Stream Java client library, is dual-licensed under the
@@ -32,18 +32,26 @@ public interface Message {
3232
/**
3333
* Does this message has a publishing ID?
3434
*
35-
* <p>Publishing IDs are used for de-duplication of outbound messages. They are not persisted.
35+
* <p>Publishing IDs are used for deduplication of outbound messages. They are not persisted.
3636
*
3737
* @return true if the message has a publishing ID, false otherwise
38+
* @see ProducerBuilder#name(String)
39+
* @see <a
40+
* href="https://rabbitmq.github.io/rabbitmq-stream-java-client/stable/htmlsingle/#outbound-message-deduplication">Deduplication
41+
* documentation</a>
3842
*/
3943
boolean hasPublishingId();
4044

4145
/**
4246
* Get the publishing ID for the message.
4347
*
44-
* <p>Publishing IDs are used for de-duplication of outbound messages. They are not persisted.
48+
* <p>Publishing IDs are used for deduplication of outbound messages. They are not persisted.
4549
*
4650
* @return the publishing ID of the message
51+
* @see ProducerBuilder#name(String)
52+
* @see <a
53+
* href="https://rabbitmq.github.io/rabbitmq-stream-java-client/stable/htmlsingle/#outbound-message-deduplication">Deduplication
54+
* documentation</a>
4755
*/
4856
long getPublishingId();
4957

src/main/java/com/rabbitmq/stream/MessageBuilder.java

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
// Copyright (c) 2020-2023 Broadcom. All Rights Reserved.
1+
// Copyright (c) 2020-2024 Broadcom. All Rights Reserved.
22
// The term "Broadcom" refers to Broadcom Inc. and/or its subsidiaries.
33
//
44
// This software, the RabbitMQ Stream Java client library, is dual-licensed under the
@@ -38,12 +38,16 @@ public interface MessageBuilder {
3838
Message build();
3939

4040
/**
41-
* Set the publishing ID (for de-duplication).
41+
* Set the publishing ID (for deduplication).
4242
*
4343
* <p>This is value is used only for outbound messages and is not persisted.
4444
*
4545
* @param publishingId
4646
* @return this builder instance
47+
* @see ProducerBuilder#name(String)
48+
* @see <a
49+
* href="https://rabbitmq.github.io/rabbitmq-stream-java-client/stable/htmlsingle/#outbound-message-deduplication">Deduplication
50+
* documentation</a>
4751
*/
4852
MessageBuilder publishingId(long publishingId);
4953

src/main/java/com/rabbitmq/stream/ProducerBuilder.java

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -23,12 +23,18 @@
2323
public interface ProducerBuilder {
2424

2525
/**
26-
* The logical name of the producer.
26+
* The producer name for deduplication (<b>read the <a
27+
* href="https://rabbitmq.github.io/rabbitmq-stream-java-client/stable/htmlsingle/#outbound-message-deduplication">documentation</a>
28+
* before use</b>).
2729
*
28-
* <p>Set a value to enable de-duplication.
30+
* <p>There must be only one producer instance at the same time using a given name.
2931
*
3032
* @param name
3133
* @return this builder instance
34+
* @see MessageBuilder#publishingId(long)
35+
* @see <a
36+
* href="https://rabbitmq.github.io/rabbitmq-stream-java-client/stable/htmlsingle/#outbound-message-deduplication">Deduplication
37+
* documentation</a>
3238
*/
3339
ProducerBuilder name(String name);
3440

0 commit comments

Comments
 (0)