Skip to content

Commit edf25f6

Browse files
janssk1acogoluegnes
janssk1
authored andcommitted
637: Default generator should not be static
Change-Id: I3bb119f3f7debeb0d45ff81dc9154e26635f03bb (cherry picked from commit 102cbbd) Conflicts: src/main/java/com/rabbitmq/client/RpcClient.java
1 parent c5691d9 commit edf25f6

File tree

2 files changed

+5
-1
lines changed

2 files changed

+5
-1
lines changed

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

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -81,7 +81,11 @@ public Response handle(Object reply) {
8181
}
8282
};
8383

84+
<<<<<<< HEAD
8485
private final RpcClientReplyHandler _replyHandler;
86+
=======
87+
private final Function<Object, Response> _replyHandler;
88+
>>>>>>> 102cbbde1... 637: Default generator should not be static
8589

8690
/** Map from request correlation ID to continuation BlockingCell */
8791
private final Map<String, BlockingCell<Object>> _continuationMap = new HashMap<String, BlockingCell<Object>>();

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -52,7 +52,7 @@ public class RpcClientParams {
5252
*/
5353
private RpcClient.RpcClientReplyHandler replyHandler = RpcClient.DEFAULT_REPLY_HANDLER;
5454

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

5757
/**
5858
* Set the channel to use for communication.

0 commit comments

Comments
 (0)