Avoid Race in FtpStreamingMessageSourceTests

garyrussell · garyrussell · commit 23843c789b46 · 2019-03-01T11:14:12.000-05:00
See #2776
diff --git a/spring-integration-ftp/src/test/java/org/springframework/integration/ftp/inbound/FtpStreamingMessageSourceTests.java b/spring-integration-ftp/src/test/java/org/springframework/integration/ftp/inbound/FtpStreamingMessageSourceTests.java
@@ -174,7 +174,7 @@ public QueueChannel data() {
 		public PollerMetadata defaultPoller() {
 			PollerMetadata pollerMetadata = new PollerMetadata();
 			pollerMetadata.setTrigger(new PeriodicTrigger(500));
-			pollerMetadata.setMaxMessagesPerPoll(2000);
+			pollerMetadata.setMaxMessagesPerPoll(1);
 			return pollerMetadata;
 		}
 

Original file line number	Diff line number	Diff line change
`@@ -174,7 +174,7 @@ public QueueChannel data() {`
`174`	`174`	`public PollerMetadata defaultPoller() {`
`175`	`175`	`PollerMetadata pollerMetadata = new PollerMetadata();`
`176`	`176`	`pollerMetadata.setTrigger(new PeriodicTrigger(500));`
`177`		`- pollerMetadata.setMaxMessagesPerPoll(2000);`
	`177`	`+ pollerMetadata.setMaxMessagesPerPoll(1);`
`178`	`178`	`return pollerMetadata;`
`179`	`179`	`}`
`180`	`180`