ns

belaban · Sep 23, 2022 · a95ba2f · a95ba2f
1 parent ee2c9ee
commit a95ba2f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/org/jgroups/protocols/BatchBundler.java b/src/org/jgroups/protocols/BatchBundler.java
@@ -235,7 +235,7 @@ protected synchronized boolean addMessage(Message msg) {
             }
 
             int msg_bytes = msg.getLength();
-            if(total_bytes + msg_bytes > transport.getBundler().getMaxSize()) {
+            if(total_bytes + msg_bytes > max_size) {
                 num_ebs_sent_due_to_full_queue++;
                 sendBatch(false);
             }