pulsar修改5

apache · Mar 7, 2023 · 81ed317 · 81ed317
1 parent 1a676cb
commit 81ed317
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...etmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/PushConsumerImpl.java b/...etmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/PushConsumerImpl.java
@@ -202,6 +202,7 @@ public EventMeshConsumeConcurrentlyStatus handleMessage(MessageExt msg,
             final Properties contextProperties = new Properties();
             contextProperties.put(NonStandardKeys.MESSAGE_CONSUME_STATUS,
                 EventMeshConsumeConcurrentlyStatus.RECONSUME_LATER.name());
+
             EventMeshAsyncConsumeContext eventMeshAsyncConsumeContext = new EventMeshAsyncConsumeContext() {
                 @Override
                 public void commit(EventMeshAction action) {