From 79bab3b269b267a487fc191f4f713cd92bcbb64b Mon Sep 17 00:00:00 2001
From: zkzlx <kiss_maple@163.com>
Date: Fri, 8 Jan 2021 17:31:20 +0800
Subject: [PATCH] test

---
 .../alibaba/cloud/examples/RocketMQConsumerApplication.java  | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/spring-cloud-alibaba-examples/rocketmq-example/rocketmq-consume-example/src/main/java/com/alibaba/cloud/examples/RocketMQConsumerApplication.java b/spring-cloud-alibaba-examples/rocketmq-example/rocketmq-consume-example/src/main/java/com/alibaba/cloud/examples/RocketMQConsumerApplication.java
index 2bd73880..0458e9ef 100644
--- a/spring-cloud-alibaba-examples/rocketmq-example/rocketmq-consume-example/src/main/java/com/alibaba/cloud/examples/RocketMQConsumerApplication.java
+++ b/spring-cloud-alibaba-examples/rocketmq-example/rocketmq-consume-example/src/main/java/com/alibaba/cloud/examples/RocketMQConsumerApplication.java
@@ -74,10 +74,13 @@ public class RocketMQConsumerApplication {
 			while (true) {
 				mySink.input5().poll(m -> {
 					String payload = (String) m.getPayload();
+					if(payload.contains("0")){
+						throw new IllegalArgumentException("111111111111111111111111111111111111111111");
+					}
 					System.out.println("pull msg: " + payload);
 				}, new ParameterizedTypeReference<String>() {
 				});
-				Thread.sleep(2_000);
+				Thread.sleep(5_00);
 			}
 		}