We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ef21961 commit cec1fb0Copy full SHA for cec1fb0
src/org/jgroups/protocols/pbcast/NAKACK2.java
@@ -252,7 +252,7 @@ public void setResendLastSeqno(boolean flag) {
252
/** Keeps a bounded list of the last N digest sets */
253
protected final BoundedList<String> digest_history=new BoundedList<>(10);
254
255
- protected Queue<Message> become_server_queue;
+ protected Queue<Message> become_server_queue=new ConcurrentLinkedQueue<>();
256
257
/** Log to suppress identical warnings for messages from non-members */
258
protected SuppressLog<Address> suppress_log_non_member;
0 commit comments