Skip to content

Commit 52c0643

Browse files
committed
Rename property
References #637
1 parent 96b24b3 commit 52c0643

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ public class RpcClient {
9090
*
9191
* @since 5.9.0
9292
*/
93-
private final Supplier<String> _correlationIdGenerator;
93+
private final Supplier<String> _correlationIdSupplier;
9494

9595
private String lastCorrelationId = "0";
9696

@@ -117,7 +117,7 @@ public RpcClient(RpcClientParams params) throws
117117
_timeout = params.getTimeout();
118118
_useMandatory = params.shouldUseMandatory();
119119
_replyHandler = params.getReplyHandler();
120-
_correlationIdGenerator = params.getCorrelationIdSupplier();
120+
_correlationIdSupplier = params.getCorrelationIdSupplier();
121121

122122
_consumer = setupConsumer();
123123
if (_useMandatory) {
@@ -216,7 +216,7 @@ public Response doCall(AMQP.BasicProperties props, byte[] message, int timeout)
216216
BlockingCell<Object> k = new BlockingCell<Object>();
217217
String replyId;
218218
synchronized (_continuationMap) {
219-
replyId = _correlationIdGenerator.get();
219+
replyId = _correlationIdSupplier.get();
220220
lastCorrelationId = replyId;
221221
props = ((props==null) ? new AMQP.BasicProperties.Builder() : props.builder())
222222
.correlationId(replyId).replyTo(_replyTo).build();

0 commit comments

Comments
 (0)