From f540bc62b80b4264cc500d95529ef3f64765c335 Mon Sep 17 00:00:00 2001 From: xwm1992 Date: Tue, 14 Dec 2021 17:23:01 +0800 Subject: [PATCH] [ISSUE #405] remove some unused code --- .../org/apache/eventmesh/api/RRCallback.java | 28 ------------ .../api/consumer/MeshMQPushConsumer.java | 40 ----------------- .../api/producer/MeshMQProducer.java | 45 ------------------- .../eventmesh/api/producer/Producer.java | 2 - 4 files changed, 115 deletions(-) delete mode 100644 eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RRCallback.java delete mode 100644 eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/consumer/MeshMQPushConsumer.java delete mode 100644 eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/producer/MeshMQProducer.java diff --git a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RRCallback.java b/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RRCallback.java deleted file mode 100644 index eba4acdbaa..0000000000 --- a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RRCallback.java +++ /dev/null @@ -1,28 +0,0 @@ -///* -// * Licensed to the Apache Software Foundation (ASF) under one or more -// * contributor license agreements. See the NOTICE file distributed with -// * this work for additional information regarding copyright ownership. -// * The ASF licenses this file to You under the Apache License, Version 2.0 -// * (the "License"); you may not use this file except in compliance with -// * the License. You may obtain a copy of the License at -// * -// * http://www.apache.org/licenses/LICENSE-2.0 -// * -// * Unless required by applicable law or agreed to in writing, software -// * distributed under the License is distributed on an "AS IS" BASIS, -// * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -// * See the License for the specific language governing permissions and -// * limitations under the License. -// */ -// -//package org.apache.eventmesh.api; -// -//import io.openmessaging.api.Message; -// -//public interface RRCallback { -// -// public void onSuccess(Message msg); -// -// public void onException(Throwable e); -// -//} diff --git a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/consumer/MeshMQPushConsumer.java b/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/consumer/MeshMQPushConsumer.java deleted file mode 100644 index 8747cd9945..0000000000 --- a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/consumer/MeshMQPushConsumer.java +++ /dev/null @@ -1,40 +0,0 @@ -///* -// * Licensed to the Apache Software Foundation (ASF) under one or more -// * contributor license agreements. See the NOTICE file distributed with -// * this work for additional information regarding copyright ownership. -// * The ASF licenses this file to You under the Apache License, Version 2.0 -// * (the "License"); you may not use this file except in compliance with -// * the License. You may obtain a copy of the License at -// * -// * http://www.apache.org/licenses/LICENSE-2.0 -// * -// * Unless required by applicable law or agreed to in writing, software -// * distributed under the License is distributed on an "AS IS" BASIS, -// * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -// * See the License for the specific language governing permissions and -// * limitations under the License. -// */ -// -//package org.apache.eventmesh.api.consumer; -// -//import java.util.List; -//import java.util.Properties; -// -//import org.apache.eventmesh.api.AbstractContext; -//import org.apache.eventmesh.spi.EventMeshExtensionType; -//import org.apache.eventmesh.spi.EventMeshSPI; -// -//@EventMeshSPI(isSingleton = false, eventMeshExtensionType = EventMeshExtensionType.CONNECTOR) -//public interface MeshMQPushConsumer extends Consumer { -// -// void init(Properties keyValue) throws Exception; -// -// void updateOffset(List msgs, AbstractContext context); -// -//// void registerMessageListener(MessageListenerConcurrently messageListenerConcurrently); -// -// void subscribe(String topic, final AsyncMessageListener listener) throws Exception; -// -// @Override -// void unsubscribe(String topic); -//} diff --git a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/producer/MeshMQProducer.java b/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/producer/MeshMQProducer.java deleted file mode 100644 index e44bd50a8e..0000000000 --- a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/producer/MeshMQProducer.java +++ /dev/null @@ -1,45 +0,0 @@ -///* -// * Licensed to the Apache Software Foundation (ASF) under one or more -// * contributor license agreements. See the NOTICE file distributed with -// * this work for additional information regarding copyright ownership. -// * The ASF licenses this file to You under the Apache License, Version 2.0 -// * (the "License"); you may not use this file except in compliance with -// * the License. You may obtain a copy of the License at -// * -// * http://www.apache.org/licenses/LICENSE-2.0 -// * -// * Unless required by applicable law or agreed to in writing, software -// * distributed under the License is distributed on an "AS IS" BASIS, -// * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. -// * See the License for the specific language governing permissions and -// * limitations under the License. -// */ -// -//package org.apache.eventmesh.api.producer; -// -//import java.util.Properties; -// -//import io.openmessaging.api.Message; -//import io.openmessaging.api.Producer; -//import io.openmessaging.api.SendCallback; -// -//import org.apache.eventmesh.api.RRCallback; -//import org.apache.eventmesh.spi.EventMeshExtensionType; -//import org.apache.eventmesh.spi.EventMeshSPI; -// -//@EventMeshSPI(isSingleton = false, eventMeshExtensionType = EventMeshExtensionType.CONNECTOR) -//public interface MeshMQProducer extends Producer { -// -// void init(Properties properties) throws Exception; -// -// void send(Message message, SendCallback sendCallback) throws Exception; -// -// void request(Message message, RRCallback rrCallback, long timeout) throws Exception; -// -// boolean reply(final Message message, final SendCallback sendCallback) throws Exception; -// -// void checkTopicExist(String topic) throws Exception; -// -// void setExtFields(); -// -//} diff --git a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/producer/Producer.java b/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/producer/Producer.java index 5f14582eac..c526215435 100644 --- a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/producer/Producer.java +++ b/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/producer/Producer.java @@ -44,8 +44,6 @@ public interface Producer extends LifeCycle { void sendAsync(final CloudEvent cloudEvent, final SendCallback sendCallback); -// void request(CloudEvent cloudEvent, RRCallback rrCallback, long timeout) throws Exception; - void request(CloudEvent cloudEvent, RequestReplyCallback rrCallback, long timeout) throws Exception; boolean reply(final CloudEvent cloudEvent, final SendCallback sendCallback) throws Exception;