You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by jo...@apache.org on 2022/12/15 03:42:34 UTC
[incubator-eventmesh] branch master updated: update log (#2607)
This is an automated email from the ASF dual-hosted git repository.
jonyang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new f619aee61 update log (#2607)
f619aee61 is described below
commit f619aee61a186adfe5e243e368ec92dddfc32853
Author: weihubeats <we...@163.com>
AuthorDate: Thu Dec 15 11:42:28 2022 +0800
update log (#2607)
---
.../core/protocol/grpc/push/AbstractPushRequest.java | 15 ++++++---------
1 file changed, 6 insertions(+), 9 deletions(-)
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/AbstractPushRequest.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/AbstractPushRequest.java
index 389caa140..a1d258fba 100644
--- a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/AbstractPushRequest.java
+++ b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/AbstractPushRequest.java
@@ -29,7 +29,6 @@ import org.apache.eventmesh.runtime.boot.EventMeshGrpcServer;
import org.apache.eventmesh.runtime.configuration.EventMeshGrpcConfiguration;
import org.apache.eventmesh.runtime.constants.EventMeshConstants;
import org.apache.eventmesh.runtime.core.protocol.grpc.consumer.EventMeshConsumer;
-import org.apache.eventmesh.runtime.core.protocol.grpc.consumer.consumergroup.ConsumerGroupTopicConfig;
import org.apache.eventmesh.runtime.core.protocol.grpc.retry.GrpcRetryer;
import org.apache.eventmesh.runtime.core.protocol.grpc.retry.RetryContext;
@@ -39,16 +38,14 @@ import java.util.Objects;
import java.util.Set;
import java.util.concurrent.atomic.AtomicBoolean;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
import io.cloudevents.CloudEvent;
import com.google.common.collect.Sets;
-public abstract class AbstractPushRequest extends RetryContext {
+import lombok.extern.slf4j.Slf4j;
- private final Logger logger = LoggerFactory.getLogger(ConsumerGroupTopicConfig.class);
+@Slf4j
+public abstract class AbstractPushRequest extends RetryContext {
protected EventMeshGrpcServer eventMeshGrpcServer;
protected long createTime = System.currentTimeMillis();
@@ -87,7 +84,7 @@ public abstract class AbstractPushRequest extends RetryContext {
ProtocolTransportObject protocolTransportObject = protocolAdaptor.fromCloudEvent(cloudEvent);
return ((SimpleMessageWrapper) protocolTransportObject).getMessage();
} catch (Exception e) {
- logger.error("Error in getting EventMeshMessage from CloudEvent", e);
+ log.error("Error in getting EventMeshMessage from CloudEvent", e);
return null;
}
}
@@ -98,7 +95,7 @@ public abstract class AbstractPushRequest extends RetryContext {
ProtocolAdaptor<ProtocolTransportObject> protocolAdaptor = ProtocolPluginFactory.getProtocolAdaptor(protocolType);
return protocolAdaptor.toCloudEvent(new SimpleMessageWrapper(simpleMessage));
} catch (Exception e) {
- logger.error("Error in getting CloudEvent from EventMeshMessage", e);
+ log.error("Error in getting CloudEvent from EventMeshMessage", e);
return null;
}
}
@@ -131,7 +128,7 @@ public abstract class AbstractPushRequest extends RetryContext {
try {
eventMeshConsumer.updateOffset(subscriptionMode, Collections.singletonList(event), context);
} catch (Exception e) {
- logger.error("Error in updating offset in EventMeshConsumer", e);
+ log.error("Error in updating offset in EventMeshConsumer", e);
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org