[servicecomb-pack] 09/21: SCB-1418 add countDownLatch field to KafkaActorEventSink

[ningjiang]

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 6438dd32d83d87bb40dd1a4d383740927b83e4eb
Author: CMonkey <42.codemon...@gmail.com>
AuthorDate: Tue Aug 13 16:38:48 2019 +0800

    SCB-1418 add countDownLatch field to KafkaActorEventSink
---
 .../pack/alpha/fsm/channel/kafka/test/KafkaActorEventSink.java       | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/alpha/alpha-fsm-channel-kafka/src/test/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/test/KafkaActorEventSink.java
 
b/alpha/alpha-fsm-channel-kafka/src/test/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/test/KafkaActorEventSink.java
index 06ed3c8..b392a94 100644
--- 
a/alpha/alpha-fsm-channel-kafka/src/test/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/test/KafkaActorEventSink.java
+++ 
b/alpha/alpha-fsm-channel-kafka/src/test/java/org/apache/servicecomb/pack/alpha/fsm/channel/kafka/test/KafkaActorEventSink.java
@@ -19,8 +19,13 @@ package 
org.apache.servicecomb.pack.alpha.fsm.channel.kafka.test;
 import org.apache.servicecomb.pack.alpha.core.fsm.event.base.BaseEvent;
 import org.apache.servicecomb.pack.alpha.core.fsm.sink.ActorEventSink;
 
+import java.util.concurrent.CountDownLatch;
+
 public class KafkaActorEventSink implements ActorEventSink {
+    public static final CountDownLatch countDownLatch = new CountDownLatch(8);
+
     @Override
     public void send(BaseEvent event) throws Exception {
+        countDownLatch.countDown();
     }
 }