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

Fix RotatingServersTestsfor proper import

Browse Source 
https://build.spring.io/browse/INT-SI50X-94/
This commit is contained in:
Artem Bilan
2018-06-27 15:29:12 -04:00
parent 9f937f54cd
commit bb174d44ab
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-integration-ftp/src/test/java/org/springframework/integration/ftp/inbound/RotatingServersTests.java
View File

@@ -39,7 +39,7 @@ import org.springframework.integration.channel.QueueChannel;
import org.springframework.integration.config.EnableIntegration;
import org.springframework.integration.dsl.IntegrationFlow;
import org.springframework.integration.dsl.IntegrationFlows;
import org.springframework.integration.dsl.MessageChannels;
import org.springframework.integration.dsl.channel.MessageChannels;
import org.springframework.integration.dsl.Pollers;
import org.springframework.integration.file.remote.session.CachingSessionFactory;
import org.springframework.integration.file.remote.session.DefaultSessionFactoryLocator;
@@ -80,6 +80,7 @@ public class RotatingServersTests extends FtpTestSupport {
s.write(bais, "foo/f1");
s.write(bais, "baz/f2");
s.write(bais, "fiz/f3");
bais.close();
return null;
});
}
@@ -127,7 +128,8 @@ public class RotatingServersTests extends FtpTestSupport {
assertThat(f1.delete()).isTrue();
assertThat(f2.delete()).isTrue();
assertThat(f3.delete()).isTrue();
assertThat(ctx.getBean("files", QueueChannel.class).getQueueSize()).isEqualTo(3);
QueueChannel files = ctx.getBean("files", QueueChannel.class);
assertThat(files.getQueueSize()).isEqualTo(3);
ctx.close();
}