File tree Expand file tree Collapse file tree 2 files changed +1
-3
lines changed
src/main/java/com/rabbitmq/client Expand file tree Collapse file tree 2 files changed +1
-3
lines changed Original file line number Diff line number Diff line change @@ -80,8 +80,6 @@ public class RpcClient {
80
80
}
81
81
};
82
82
83
- public static Supplier <String > DEFAULT_CORRELATION_ID_GENERATOR = new IncrementingCorrelationIdGenerator ("" );
84
-
85
83
private final Function <Object , Response > _replyHandler ;
86
84
87
85
/** Map from request correlation ID to continuation BlockingCell */
Original file line number Diff line number Diff line change @@ -55,7 +55,7 @@ public class RpcClientParams {
55
55
*/
56
56
private Function <Object , RpcClient .Response > replyHandler = RpcClient .DEFAULT_REPLY_HANDLER ;
57
57
58
- private Supplier <String > correlationIdGenerator = RpcClient . DEFAULT_CORRELATION_ID_GENERATOR ;
58
+ private Supplier <String > correlationIdGenerator = new IncrementingCorrelationIdGenerator ( "" ) ;
59
59
60
60
/**
61
61
* Set the channel to use for communication.
You can’t perform that action at this time.
0 commit comments