This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/servicecomb-pack.git
commit 0ef23fb5fd83eaf3b0218ae1607da6bf6bd093b0 Author: CMonkey <[email protected]> AuthorDate: Tue Aug 13 16:38:32 2019 +0800 SCB-1418 add test actorEventSink to KafkaChannelTest --- .../pack/alpha/fsm/channel/kafka/test/KafkaChannelTest.java | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/alpha/alpha-fsm-channel-kafka/src/test/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/test/KafkaChannelTest.java b/alpha/alpha-fsm-channel-kafka/src/test/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/test/KafkaChannelTest.java index 68d650a..942b16d 100644 --- a/alpha/alpha-fsm-channel-kafka/src/test/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/test/KafkaChannelTest.java +++ b/alpha/alpha-fsm-channel-kafka/src/test/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/test/KafkaChannelTest.java @@ -34,6 +34,8 @@ import org.springframework.test.context.junit4.SpringRunner; import java.util.*; import java.util.concurrent.TimeUnit; +import static org.junit.Assert.assertEquals; + @RunWith(SpringRunner.class) @SpringBootTest(classes = KafkaApplication.class, @@ -52,6 +54,9 @@ public class KafkaChannelTest { @Autowired private KafkaMessagePublisher kafkaMessagePublisher; + @Autowired + private KafkaActorEventSink actorEventSink; + @Before public void setup(){ } @@ -66,11 +71,13 @@ public class KafkaChannelTest { buildData(globalTxId, localTxId_1, localTxId_2, localTxId_3).forEach(baseEvent -> kafkaMessagePublisher.publish(baseEvent)); try { - TimeUnit.SECONDS.sleep(100); + // Waiting for sub + TimeUnit.SECONDS.sleep(5); } catch (InterruptedException e) { - e.printStackTrace(); } + assertEquals(0, actorEventSink.countDownLatch.getCount()); + } private List<BaseEvent> buildData(String globalTxId, String localTxId_1, String localTxId_2, String localTxId_3){
