move SubscribeTask.java to client package

pmupkin · Sep 20, 2022 · 244974a · 244974a
1 parent a26427c
commit 244974a
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 3 deletions.
diff --git a/...or-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaClient.java b/...or-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaClient.java
@@ -19,7 +19,6 @@
 
 import org.apache.eventmesh.api.EventListener;
 import org.apache.eventmesh.api.SendResult;
-import org.apache.eventmesh.connector.pravega.SubscribeTask;
 import org.apache.eventmesh.connector.pravega.config.PravegaConnectorConfig;
 import org.apache.eventmesh.connector.pravega.exception.PravegaConnectorException;
 

diff --git a/...mesh/connector/pravega/SubscribeTask.java → ...nnector/pravega/client/SubscribeTask.java b/...mesh/connector/pravega/SubscribeTask.java → ...nnector/pravega/client/SubscribeTask.java
@@ -15,12 +15,11 @@
  * limitations under the License.
  */
 
-package org.apache.eventmesh.connector.pravega;
+package org.apache.eventmesh.connector.pravega.client;
 
 import org.apache.eventmesh.api.EventListener;
 import org.apache.eventmesh.api.EventMeshAction;
 import org.apache.eventmesh.api.EventMeshAsyncConsumeContext;
-import org.apache.eventmesh.connector.pravega.client.PravegaEvent;
 
 import java.util.concurrent.atomic.AtomicBoolean;