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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
