SpringCloud/spring-cloud-contract
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Update Spring Boot versions in messaging tests

Browse Source
This commit is contained in:
Dave Syer
2017-05-15 11:41:09 +01:00
parent c7f5accae4
commit 2f01b89345
5 changed files with 17 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
samples/standalone/messaging/stream-sink/src/test/java/com/example/sink/MessageConsumedTests.java
View File

@@ -18,13 +18,20 @@ package com.example.sink;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.boot.test.context.SpringBootTest.WebEnvironment;
import org.springframework.cloud.contract.stubrunner.StubTrigger;
import org.springframework.cloud.contract.stubrunner.spring.AutoConfigureStubRunner;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.integration.support.management.MessageChannelMetrics;
import org.springframework.messaging.SubscribableChannel;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import static org.assertj.core.api.Assertions.assertThat;
/**
* @author Marius Bogoevici
*/
@@ -36,8 +43,14 @@ public class MessageConsumedTests {
@Autowired
StubTrigger stubTrigger;
@Autowired
@Qualifier(Sink.INPUT)
SubscribableChannel input;
@Test
public void testMessageConsumed() throws Exception {
int count = ((MessageChannelMetrics) input).getSendCount();
stubTrigger.trigger("sensor1");
assertThat(((MessageChannelMetrics) input).getSendCount()).isEqualTo(count + 1);
}
}