support sendOneway method

apache · Sep 21, 2022 · 0c1fcb7 · 0c1fcb7
1 parent 93426af
commit 0c1fcb7
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...tor-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaProducerImpl.java b/...tor-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaProducerImpl.java
@@ -81,7 +81,7 @@ public void publish(CloudEvent cloudEvent, SendCallback sendCallback) throws Exc
 
     @Override
     public void sendOneway(CloudEvent cloudEvent) {
-        throw new UnsupportedOperationException();
+        client.publish(cloudEvent.getSubject(), cloudEvent);
     }
 
     @Override