You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by mi...@apache.org on 2022/10/27 08:53:08 UTC

[incubator-eventmesh] branch master updated: fix: Method calls String.format on a static (non parameterized) format string [PulsarConsumerImpl]

This is an automated email from the ASF dual-hosted git repository.

mikexue 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 413e63be fix: Method calls String.format on a static (non parameterized) format string  [PulsarConsumerImpl]
     new 107a0d2a Merge pull request #1962 from ocean-gao/fix_patch_string
413e63be is described below

commit 413e63bec9226a4a51a1616ed2b3138e4e285f15
Author: ocean-gao <ga...@163.com>
AuthorDate: Thu Oct 27 14:21:47 2022 +0800

    fix: Method calls String.format on a static (non parameterized) format string  [PulsarConsumerImpl]
---
 .../apache/eventmesh/connector/pulsar/producer/AbstractProducer.java  | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/AbstractProducer.java b/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/AbstractProducer.java
index 12d0217e..f0e4858e 100644
--- a/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/AbstractProducer.java
+++ b/eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/AbstractProducer.java
@@ -40,9 +40,9 @@ public abstract class AbstractProducer {
 
     ConnectorRuntimeException checkProducerException(CloudEvent cloudEvent, Throwable e) {
         if (cloudEvent.getData() == null) {
-            return new ConnectorRuntimeException(String.format("CloudEvent message data does not exist.", e));
+            return new ConnectorRuntimeException(String.format("CloudEvent message data does not exist, %s", e.getMessage()));
         }
-        return new ConnectorRuntimeException(String.format("Unknown connector runtime exception.", e));
+        return new ConnectorRuntimeException(String.format("Unknown connector runtime exception, %s", e.getMessage()));
     }
 
     public boolean isStarted() {


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org