This is an automated email from the ASF dual-hosted git repository.
pandaapo pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new 0250a8940 [ISSUE #4785] Condition check for source worker (#4786)
0250a8940 is described below
commit 0250a894078710a508af53b6a95c4171b97af16d
Author: manojks1999 <[email protected]>
AuthorDate: Sun Mar 10 07:04:57 2024 +0530
[ISSUE #4785] Condition check for source worker (#4786)
* condition_check_for_source_eorker
* ci_typo_fix
* import_order_fix
---
.../src/main/java/org/apache/eventmesh/openconnect/SourceWorker.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/SourceWorker.java
b/eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/SourceWorker.java
index c5d4fe2b0..b971d0b98 100644
---
a/eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/SourceWorker.java
+++
b/eventmesh-openconnect/eventmesh-openconnect-java/src/main/java/org/apache/eventmesh/openconnect/SourceWorker.java
@@ -24,6 +24,7 @@ import
org.apache.eventmesh.client.tcp.EventMeshTCPClientFactory;
import org.apache.eventmesh.client.tcp.common.MessageUtils;
import org.apache.eventmesh.client.tcp.conf.EventMeshTCPClientConfig;
import org.apache.eventmesh.common.exception.EventMeshException;
+import org.apache.eventmesh.common.protocol.tcp.OPStatus;
import org.apache.eventmesh.common.protocol.tcp.Package;
import org.apache.eventmesh.common.protocol.tcp.UserAgent;
import org.apache.eventmesh.common.utils.JsonUtils;
@@ -196,7 +197,7 @@ public class SourceWorker implements ConnectorWorker {
while (retryTimes < MAX_RETRY_TIMES) {
try {
Package sendResult = eventMeshTCPClient.publish(event,
3000);
- if (sendResult.getHeader().getCode() == 0) {
+ if (sendResult.getHeader().getCode() ==
OPStatus.SUCCESS.getCode()) {
// publish success
// commit record
this.source.commit(connectRecord);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
