Increase number of messages

acogoluegnes · acogoluegnes · commit be11c8fe5981 · 2025-08-12T07:39:48.000+02:00
diff --git a/src/test/java/com/rabbitmq/client/test/functional/Confirm.java b/src/test/java/com/rabbitmq/client/test/functional/Confirm.java
@@ -41,7 +41,7 @@
 
 public class Confirm extends BrokerTestCase
 {
-    private final static int NUM_MESSAGES = 1000;
+    private final static int NUM_MESSAGES = 10_000;
 
     private static final String TTL_ARG = "x-message-ttl";
 
diff --git a/src/test/java/com/rabbitmq/client/test/functional/RequeueOnClose.java b/src/test/java/com/rabbitmq/client/test/functional/RequeueOnClose.java
@@ -40,7 +40,7 @@ public abstract class RequeueOnClose
     extends BrokerTestCase
 {
     private static final String Q = "RequeueOnClose";
-    private static final int MESSAGE_COUNT = 2000;
+    private static final int MESSAGE_COUNT = 10_000;
 
     protected abstract void open() throws IOException, TimeoutException;
 

Original file line number	Diff line number	Diff line change
`@@ -41,7 +41,7 @@`
`41`	`41`
`42`	`42`	`public class Confirm extends BrokerTestCase`
`43`	`43`	`{`
`44`		`- private final static int NUM_MESSAGES = 1000;`
	`44`	`+ private final static int NUM_MESSAGES = 10_000;`
`45`	`45`
`46`	`46`	`private static final String TTL_ARG = "x-message-ttl";`
`47`	`47`
Original file line number	Diff line number	Diff line change
`@@ -40,7 +40,7 @@ public abstract class RequeueOnClose`
`40`	`40`	`extends BrokerTestCase`
`41`	`41`	`{`
`42`	`42`	`private static final String Q = "RequeueOnClose";`
`43`		`- private static final int MESSAGE_COUNT = 2000;`
	`43`	`+ private static final int MESSAGE_COUNT = 10_000;`
`44`	`44`
`45`	`45`	`protected abstract void open() throws IOException, TimeoutException;`
`46`	`46`