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

TCP: Fix Event Tests Race Condition

Browse Source
This commit is contained in:
Gary Russell
2015-08-14 13:05:50 -04:00
parent a5e5a7b125
commit d5dcb419c3
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
spring-integration-ip/src/test/java/org/springframework/integration/ip/tcp/connection/ConnectionFactoryTests.java
View File

@@ -16,6 +16,7 @@
package org.springframework.integration.ip.tcp.connection;
import static org.hamcrest.Matchers.greaterThanOrEqualTo;
import static org.hamcrest.Matchers.hasItem;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertThat;
@@ -130,8 +131,8 @@ public class ConnectionFactoryTests {
clients = clientFactory.getOpenConnectionIds();
assertEquals(0, clients.size());
int expected = serverFactory instanceof TcpNetServerConnectionFactory ? 6// OPEN, CLOSE, EXCEPTION for each side
: 4; //OPEN, CLOSE
assertEquals(expected, events.size());
: 4; //OPEN, CLOSE (but we *might* get exceptions, depending on timing).
assertThat(events.size(), greaterThanOrEqualTo(expected));
FooEvent event = new FooEvent(client, "foo");
client.publishEvent(event);