Adjusted timeouts for build server.
This commit is contained in:
@@ -65,7 +65,7 @@ public class FixedDelayConsumerTests {
|
||||
for (int i = 0; i < messagesToSend; i++) {
|
||||
channel.send(new GenericMessage<String>(1, "test " + (i+1)));
|
||||
}
|
||||
latch.await(1000, TimeUnit.MILLISECONDS);
|
||||
latch.await(2000, TimeUnit.MILLISECONDS);
|
||||
assertEquals(messagesToSend, counter.get());
|
||||
}
|
||||
|
||||
|
||||
@@ -204,7 +204,7 @@ public class PointToPointChannelTests {
|
||||
public boolean accept(Message<?> message) {
|
||||
return (((Integer)message.getId()).intValue() == 3);
|
||||
}
|
||||
}, 100);
|
||||
}, 500);
|
||||
messageRef.set(message);
|
||||
latch.countDown();
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user