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

GH-2364 fix intermittent failing test

Browse Source 
Resolves https://github.com/spring-projects/spring-integration/issues/2364
This commit is contained in:
Kiel Boatman
2018-02-18 17:25:58 +00:00
committed by Gary Russell
parent 4397807a57
commit 4bb4a0187a
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
spring-integration-core/src/test/java/org/springframework/integration/endpoint/PollingConsumerEndpointTests.java
View File

@@ -45,6 +45,7 @@ import org.springframework.util.ErrorHandler;
/**
* @author Iwein Fuld
* @author Mark Fisher
* @author Kiel Boatman
*/
@SuppressWarnings("unchecked")
public class PollingConsumerEndpointTests {
@@ -63,13 +64,14 @@ public class PollingConsumerEndpointTests {
private final TestErrorHandler errorHandler = new TestErrorHandler();
private final PollableChannel channelMock = Mockito.mock(PollableChannel.class);
private PollableChannel channelMock;
private final ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
@Before
public void init() throws Exception {
channelMock = Mockito.mock(PollableChannel.class);
consumer.counter.set(0);
trigger.reset();
endpoint = new PollingConsumer(channelMock, consumer);
@@ -81,7 +83,6 @@ public class PollingConsumerEndpointTests {
endpoint.setReceiveTimeout(-1);
endpoint.afterPropertiesSet();
taskScheduler.afterPropertiesSet();
Mockito.reset(channelMock);
}
@After