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

INT-1884 bumped the timeout in JdbcMessageStoreChannelIntegrationTests which intermittently fails localy and in CI

Browse Source
This commit is contained in:
Oleg Zhurakousky
2011-07-26 20:35:22 -04:00
parent 8ce5193f29
commit cd1c4b1c45
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-integration-jdbc/src/test/java/org/springframework/integration/jdbc/JdbcMessageStoreChannelTests.java
View File

@@ -56,7 +56,7 @@ public class JdbcMessageStoreChannelTests {
public void testSendAndActivate() throws Exception { public void testSendAndActivate() throws Exception {
Service.reset(1); Service.reset(1);
input.send(new GenericMessage<String>("foo")); input.send(new GenericMessage<String>("foo"));
Service.await(1000); Service.await(10000);
assertEquals(1, Service.messages.size()); assertEquals(1, Service.messages.size());
assertEquals(0, messageStore.getMessageGroup("input-queue").size()); assertEquals(0, messageStore.getMessageGroup("input-queue").size());
} }
@@ -66,7 +66,7 @@ public class JdbcMessageStoreChannelTests {
Service.reset(1); Service.reset(1);
Service.fail = true; Service.fail = true;
input.send(new GenericMessage<String>("foo")); input.send(new GenericMessage<String>("foo"));
Service.await(1000); Service.await(10000);
assertEquals(1, Service.messages.size()); assertEquals(1, Service.messages.size());
// After a rollback in the poller the message is still waiting to be delivered // After a rollback in the poller the message is still waiting to be delivered
assertEquals(1, messageStore.getMessageGroup("input-queue").size()); assertEquals(1, messageStore.getMessageGroup("input-queue").size());
@@ -80,7 +80,7 @@ public class JdbcMessageStoreChannelTests {
input.send(new GenericMessage<String>("foo")); input.send(new GenericMessage<String>("foo"));
// This will time out because the transaction has not committed yet // This will time out because the transaction has not committed yet
try { try {
Service.await(1000); Service.await(10000);
fail("Expected timeout"); fail("Expected timeout");
} catch (IllegalStateException e) { } catch (IllegalStateException e) {
// expected // expected