Spring/spring-amqp
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

AMQP-275 Reduce StopStart Test Size

Browse Source 
Reduce number of messages
Reduce concurrency and prefetch
Increase stop/start frequency
This commit is contained in:
Gary Russell
2012-11-05 15:48:37 -05:00
parent c675a7ff32
commit dd54e66fab
3 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-rabbit/src/main/java/org/springframework/amqp/rabbit/connection/RabbitUtils.java
View File

@@ -163,7 +163,7 @@ public abstract class RabbitUtils {
/**
* Gets and removes a ThreadLocal indicating the channel MUST be physically closed.
* @return
* @return true if the channel must be physically closed
*/
public static boolean isPhysicalCloseRequired() {
Boolean mustClose = physicalCloseRequired.get();

4
spring-rabbit/src/test/java/org/springframework/amqp/rabbit/listener/StopStartIntegrationTests.java
View File

@@ -45,7 +45,7 @@ public class StopStartIntegrationTests {
private static AtomicInteger deliveries = new AtomicInteger();
private static int COUNT = 300000;
private static int COUNT = 10000;
@Autowired
private ApplicationContext ctx;
@@ -66,7 +66,7 @@ public class StopStartIntegrationTests {
int n;
int lastN = 0;
while ((n = deliveries.get()) < COUNT) {
Thread.sleep(5000);
Thread.sleep(2000);
container.stop();
container.start();
if (System.currentTimeMillis() - t > 240000 && lastN == n) {

2
spring-rabbit/src/test/resources/org/springframework/amqp/rabbit/listener/StopStartIntegrationTests-context.xml
View File

@@ -20,7 +20,7 @@
</rabbit:bindings>
</rabbit:direct-exchange>
<rabbit:listener-container connection-factory="connectionFactory" concurrency="10" prefetch="20" auto-startup="false">
<rabbit:listener-container connection-factory="connectionFactory" concurrency="2" prefetch="5" auto-startup="false">
<rabbit:listener ref="listener" queue-names="stop.start.queue" />
</rabbit:listener-container>