pull/1935/head
zkzlx 4 years ago
parent 4dd45a4709
commit 79bab3b269

@ -74,10 +74,13 @@ public class RocketMQConsumerApplication {
while (true) { while (true) {
mySink.input5().poll(m -> { mySink.input5().poll(m -> {
String payload = (String) m.getPayload(); String payload = (String) m.getPayload();
if(payload.contains("0")){
throw new IllegalArgumentException("111111111111111111111111111111111111111111");
}
System.out.println("pull msg: " + payload); System.out.println("pull msg: " + payload);
}, new ParameterizedTypeReference<String>() { }, new ParameterizedTypeReference<String>() {
}); });
Thread.sleep(2_000); Thread.sleep(5_00);
} }
} }

Loading…
Cancel
Save