Skip to content

Commit 102cbbd

Browse files
author
janssk1
committed
637: Default generator should not be static
Change-Id: I3bb119f3f7debeb0d45ff81dc9154e26635f03bb
1 parent e554e4b commit 102cbbd

File tree

2 files changed

+1
-3
lines changed

2 files changed

+1
-3
lines changed

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

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -80,8 +80,6 @@ public class RpcClient {
8080
}
8181
};
8282

83-
public static Supplier<String> DEFAULT_CORRELATION_ID_GENERATOR = new IncrementingCorrelationIdGenerator("");
84-
8583
private final Function<Object, Response> _replyHandler;
8684

8785
/** Map from request correlation ID to continuation BlockingCell */

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ public class RpcClientParams {
5555
*/
5656
private Function<Object, RpcClient.Response> replyHandler = RpcClient.DEFAULT_REPLY_HANDLER;
5757

58-
private Supplier<String> correlationIdGenerator = RpcClient.DEFAULT_CORRELATION_ID_GENERATOR;
58+
private Supplier<String> correlationIdGenerator = new IncrementingCorrelationIdGenerator("");
5959

6060
/**
6161
* Set the channel to use for communication.

0 commit comments

Comments
 (0)