提交 e9a74c85 编写于 作者: wu-sheng's avatar wu-sheng

Fix a test case.

上级 f8470e6f
...@@ -83,7 +83,7 @@ public class ConsumerTest { ...@@ -83,7 +83,7 @@ public class ConsumerTest {
} }
@Test @Test
public void testConsumerOnError() { public void testConsumerOnError() throws InterruptedException {
final DataCarrier<SampleData> carrier = new DataCarrier<SampleData>(2, 100); final DataCarrier<SampleData> carrier = new DataCarrier<SampleData>(2, 100);
for (int i = 0; i < 200; i++) { for (int i = 0; i < 200; i++) {
...@@ -94,6 +94,8 @@ public class ConsumerTest { ...@@ -94,6 +94,8 @@ public class ConsumerTest {
consumer.onError = true; consumer.onError = true;
carrier.consume(consumer, 5); carrier.consume(consumer, 5);
Thread.sleep(3 * 1000L);
Assert.assertTrue(IS_OCCUR_ERROR); Assert.assertTrue(IS_OCCUR_ERROR);
} }
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册