[ROCKETMQ-17] Develop a vendor-neutral open standard for distributed messaging: reformat code as new code style /style/rmq_codeStyle.xml ASF JIRA: https://issues.apache.org/jira/browse/ROCKETMQ-17
Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/554d30aa Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/554d30aa Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/554d30aa Branch: refs/heads/spec Commit: 554d30aa80f9db18af384435d6e1b862a47998a1 Parents: 2f14f71 Author: vintagewang <[email protected]> Authored: Thu Dec 29 11:03:49 2016 +0800 Committer: vintagewang <[email protected]> Committed: Thu Dec 29 11:03:49 2016 +0800 ---------------------------------------------------------------------- .../java/org/apache/openmessaging/BytesMessage.java | 1 - .../main/java/org/apache/openmessaging/KeyValue.java | 1 - .../main/java/org/apache/openmessaging/Message.java | 1 - .../org/apache/openmessaging/MessageFactory.java | 1 - .../org/apache/openmessaging/MessagingEndPoint.java | 1 - .../openmessaging/MessagingEndPointManager.java | 6 ++---- .../main/java/org/apache/openmessaging/Producer.java | 1 - .../java/org/apache/openmessaging/PullConsumer.java | 1 - .../java/org/apache/openmessaging/PushConsumer.java | 1 - .../openmessaging/exception/OMSRuntimeException.java | 1 - .../internal/MessagingEndPointAdapter.java | 15 ++++++--------- .../internal/MessagingEndPointFactory.java | 7 +++---- .../openmessaging/internal/ServiceConstants.java | 1 - .../apache/openmessaging/internal/URISpecParser.java | 4 ++-- .../apache/openmessaging/samples/ProducerApp.java | 12 +++++------- .../wireapi/broker/BrokerAdminWireAPI.java | 1 - .../wireapi/broker/BrokerConsumeWireAPI.java | 1 - .../wireapi/broker/BrokerProduceWireAPI.java | 1 - .../openmessaging/wireapi/broker/ConnectRequest.java | 1 - .../apache/openmessaging/wireapi/broker/Message.java | 2 -- .../wireapi/broker/SendBatchRequest.java | 1 - .../wireapi/broker/SendBatchResponse.java | 1 - .../openmessaging/wireapi/broker/SendOneRequest.java | 1 - .../wireapi/broker/SendOneResponse.java | 1 - .../wireapi/broker/SendOrderRequest.java | 1 - .../wireapi/broker/SendOrderResponse.java | 1 - .../apache/openmessaging/wireapi/broker/Session.java | 1 - .../openmessaging/wireapi/broker/Subscription.java | 1 - .../wireapi/client/ClientCallbackWireAPI.java | 1 - .../wireapi/consumer/ConsumerCallbackWireAPI.java | 1 - .../wireapi/consumer/ConsumerSelfWireAPI.java | 1 - .../wireapi/naming/MetaServiceWireAPI.java | 1 - .../wireapi/naming/NameClientReadWireAPI.java | 1 - .../wireapi/naming/NameClientWriteWireAPI.java | 1 - .../wireapi/producer/ProducerCallbackWireAPI.java | 1 - 35 files changed, 18 insertions(+), 57 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/BytesMessage.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/BytesMessage.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/BytesMessage.java index 9d882cc..32fed47 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/BytesMessage.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/BytesMessage.java @@ -16,7 +16,6 @@ */ package org.apache.openmessaging; - public interface BytesMessage extends Message { BytesMessage putHeader(final String key, final int value); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/KeyValue.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/KeyValue.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/KeyValue.java index 87acf57..0b5f275 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/KeyValue.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/KeyValue.java @@ -16,7 +16,6 @@ */ package org.apache.openmessaging; - public interface KeyValue { KeyValue put(final String key, final int value); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/Message.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/Message.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/Message.java index 5563c46..589fa0b 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/Message.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/Message.java @@ -16,7 +16,6 @@ */ package org.apache.openmessaging; - public interface Message { KeyValue headers(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageFactory.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageFactory.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageFactory.java index 94e8ecf..669153b 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageFactory.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageFactory.java @@ -16,7 +16,6 @@ */ package org.apache.openmessaging; - public interface MessageFactory { BytesMessage createBytesMessage(final String topic, final byte[] body); } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessagingEndPoint.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessagingEndPoint.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessagingEndPoint.java index d24ec04..b95423f 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessagingEndPoint.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessagingEndPoint.java @@ -16,7 +16,6 @@ */ package org.apache.openmessaging; - public interface MessagingEndPoint { void start(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessagingEndPointManager.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessagingEndPointManager.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessagingEndPointManager.java index 07796d3..bb70ff4 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessagingEndPointManager.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessagingEndPointManager.java @@ -16,12 +16,10 @@ */ package org.apache.openmessaging; -import org.apache.openmessaging.internal.MessagingEndPointFactory; -import org.apache.openmessaging.internal.URISpecParser; - import java.util.List; import java.util.Map; - +import org.apache.openmessaging.internal.MessagingEndPointFactory; +import org.apache.openmessaging.internal.URISpecParser; public class MessagingEndPointManager { public static MessagingEndPoint getMessagingEndPoint(String url) { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/Producer.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/Producer.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/Producer.java index 05eb15c..35d90d4 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/Producer.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/Producer.java @@ -16,7 +16,6 @@ */ package org.apache.openmessaging; - public interface Producer extends MessageFactory { void start(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/PullConsumer.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/PullConsumer.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/PullConsumer.java index fa65543..27c4279 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/PullConsumer.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/PullConsumer.java @@ -16,7 +16,6 @@ */ package org.apache.openmessaging; - public interface PullConsumer { } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/PushConsumer.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/PushConsumer.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/PushConsumer.java index d27cab8..86025e4 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/PushConsumer.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/PushConsumer.java @@ -16,7 +16,6 @@ */ package org.apache.openmessaging; - public interface PushConsumer { } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSRuntimeException.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSRuntimeException.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSRuntimeException.java index ee38600..c10c47b 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSRuntimeException.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSRuntimeException.java @@ -14,7 +14,6 @@ * See the License for the specific language governing permissions and * limitations under the License. */ - package org.apache.openmessaging.exception; public class OMSRuntimeException extends RuntimeException { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/internal/MessagingEndPointAdapter.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/internal/MessagingEndPointAdapter.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/internal/MessagingEndPointAdapter.java index f5f2711..8c79b3c 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/internal/MessagingEndPointAdapter.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/internal/MessagingEndPointAdapter.java @@ -16,27 +16,24 @@ */ package org.apache.openmessaging.internal; - -import org.apache.openmessaging.MessagingEndPoint; - import java.lang.reflect.Constructor; import java.lang.reflect.InvocationTargetException; import java.util.HashMap; import java.util.Map; import java.util.Properties; - +import org.apache.openmessaging.MessagingEndPoint; class MessagingEndPointAdapter { private static Map<String, String> serviceEndPointClassMap = new HashMap<String, String>(); static { serviceEndPointClassMap.put(ServiceConstants.DEFAULT_SERVICE_END_POINT, - ServiceConstants.DEFAULT_SERVICE_IMPL); + ServiceConstants.DEFAULT_SERVICE_IMPL); } static MessagingEndPoint instantiateMessagingEndPoint(String url, Properties properties) - throws ClassNotFoundException, NoSuchMethodException, IllegalAccessException, - InvocationTargetException, InstantiationException { + throws ClassNotFoundException, NoSuchMethodException, IllegalAccessException, + InvocationTargetException, InstantiationException { String serviceImpl = ServiceConstants.DEFAULT_SERVICE_IMPL; if (serviceEndPointClassMap.containsKey(url)) serviceImpl = serviceEndPointClassMap.get(url); @@ -46,7 +43,7 @@ class MessagingEndPointAdapter { String serviceUrl = ServiceConstants.DEFAULT_SERVICE_DISCOVERY_URL; if (properties.get(ServiceConstants.URL) != null) { - String[] propertySplits = ((String) properties.get(ServiceConstants.URL)).split(ServiceConstants.PARAM_SEPARATOR); + String[] propertySplits = ((String)properties.get(ServiceConstants.URL)).split(ServiceConstants.PARAM_SEPARATOR); if (propertySplits.length > 0) { serviceUrl = propertySplits[0]; for (int index = 1; index < propertySplits.length; index++) { @@ -60,6 +57,6 @@ class MessagingEndPointAdapter { Class[] paramTypes = {Properties.class}; Constructor constructor = serviceEndPointClass.getConstructor(paramTypes); assert constructor != null; - return (MessagingEndPoint) constructor.newInstance(properties); + return (MessagingEndPoint)constructor.newInstance(properties); } } \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/internal/MessagingEndPointFactory.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/internal/MessagingEndPointFactory.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/internal/MessagingEndPointFactory.java index ea1a395..c3c963c 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/internal/MessagingEndPointFactory.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/internal/MessagingEndPointFactory.java @@ -16,12 +16,10 @@ */ package org.apache.openmessaging.internal; -import org.apache.openmessaging.MessagingEndPoint; - import java.util.List; import java.util.Map; import java.util.Properties; - +import org.apache.openmessaging.MessagingEndPoint; public class MessagingEndPointFactory { public static MessagingEndPoint createMessagingEndPoint(Map<String, List<String>> url, Properties properties) { @@ -31,7 +29,8 @@ public class MessagingEndPointFactory { properties.put(ServiceConstants.URL, urls.get(0)); try { return MessagingEndPointAdapter.instantiateMessagingEndPoint(driver.get(0), properties); - } catch (Exception e) { + } + catch (Exception e) { throw new RuntimeException("createMessagingEndPoint exception", e); } } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/internal/ServiceConstants.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/internal/ServiceConstants.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/internal/ServiceConstants.java index 7fc899f..19c4057 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/internal/ServiceConstants.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/internal/ServiceConstants.java @@ -16,7 +16,6 @@ */ package org.apache.openmessaging.internal; - class ServiceConstants { public static final String PROTOCOL_NAME = "protocol"; public static final String SPI_NAME = "spi"; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/internal/URISpecParser.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/internal/URISpecParser.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/internal/URISpecParser.java index d2ec999..8a69c0b 100644 --- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/internal/URISpecParser.java +++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/internal/URISpecParser.java @@ -22,7 +22,6 @@ import java.util.HashMap; import java.util.List; import java.util.Map; - public class URISpecParser { public static Map<String, List<String>> parseURI(String uri) { if (uri == null || uri.length() == 0) { @@ -41,7 +40,8 @@ public class URISpecParser { spiIndex = uri.indexOf(ServiceConstants.URL_SEPARATOR, index + 1); if (spiIndex > 0) { spi = uri.substring(index + 1, spiIndex); - } else { + } + else { spi = uri.substring(index + 1); } List<String> spiSet = new ArrayList<String>(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/ProducerApp.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/ProducerApp.java b/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/ProducerApp.java index 630d372..16f6b3f 100644 --- a/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/ProducerApp.java +++ b/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/ProducerApp.java @@ -16,13 +16,11 @@ */ package org.apache.openmessaging.samples; - +import java.nio.charset.Charset; import org.apache.openmessaging.MessagingEndPoint; import org.apache.openmessaging.MessagingEndPointManager; import org.apache.openmessaging.Producer; -import java.nio.charset.Charset; - public class ProducerApp { public static void main(String[] args) { final MessagingEndPoint messagingEndPoint = MessagingEndPointManager.getMessagingEndPoint("openmessaging:rocketmq://localhost:10911/namespace"); @@ -47,10 +45,10 @@ public class ProducerApp { System.out.println("send first message OK"); producer.send(producer.createBytesMessage("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8"))) - .putProperties("KEY1", 100)// - .putProperties("KEY2", 200L)// - .putProperties("KEY3", 3.14)// - .putProperties("KEY4", "value4")// + .putProperties("KEY1", 100)// + .putProperties("KEY2", 200L)// + .putProperties("KEY3", 3.14)// + .putProperties("KEY4", "value4")// ); System.out.println("send second message OK"); } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/BrokerAdminWireAPI.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/BrokerAdminWireAPI.java b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/BrokerAdminWireAPI.java index a57d5d5..e71289e 100644 --- a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/BrokerAdminWireAPI.java +++ b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/BrokerAdminWireAPI.java @@ -16,6 +16,5 @@ */ package org.apache.openmessaging.wireapi.broker; - public interface BrokerAdminWireAPI { } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/BrokerConsumeWireAPI.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/BrokerConsumeWireAPI.java b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/BrokerConsumeWireAPI.java index a8019e2..b96d5a8 100644 --- a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/BrokerConsumeWireAPI.java +++ b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/BrokerConsumeWireAPI.java @@ -16,7 +16,6 @@ */ package org.apache.openmessaging.wireapi.broker; - public interface BrokerConsumeWireAPI { Session connect(ConnectRequest request); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/BrokerProduceWireAPI.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/BrokerProduceWireAPI.java b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/BrokerProduceWireAPI.java index d5bb6b8..f8a2424 100644 --- a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/BrokerProduceWireAPI.java +++ b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/BrokerProduceWireAPI.java @@ -16,7 +16,6 @@ */ package org.apache.openmessaging.wireapi.broker; - public interface BrokerProduceWireAPI { Session connect(ConnectRequest request); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/ConnectRequest.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/ConnectRequest.java b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/ConnectRequest.java index 17ffd07..0f436a3 100644 --- a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/ConnectRequest.java +++ b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/ConnectRequest.java @@ -16,7 +16,6 @@ */ package org.apache.openmessaging.wireapi.broker; - public class ConnectRequest { private String localHostIP; private String authKey; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/Message.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/Message.java b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/Message.java index a611b58..aecb963 100644 --- a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/Message.java +++ b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/Message.java @@ -16,10 +16,8 @@ */ package org.apache.openmessaging.wireapi.broker; - import java.util.Map; - public class Message { private Map<String, String> systemHeader; private Map<String, String> userHeader; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendBatchRequest.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendBatchRequest.java b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendBatchRequest.java index 73a6542..ed59f69 100644 --- a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendBatchRequest.java +++ b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendBatchRequest.java @@ -16,7 +16,6 @@ */ package org.apache.openmessaging.wireapi.broker; - public class SendBatchRequest { private Message message; } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendBatchResponse.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendBatchResponse.java b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendBatchResponse.java index 3a70e64..e17a29e 100644 --- a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendBatchResponse.java +++ b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendBatchResponse.java @@ -16,6 +16,5 @@ */ package org.apache.openmessaging.wireapi.broker; - public class SendBatchResponse { } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendOneRequest.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendOneRequest.java b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendOneRequest.java index 1b59463..7645fb0 100644 --- a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendOneRequest.java +++ b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendOneRequest.java @@ -16,7 +16,6 @@ */ package org.apache.openmessaging.wireapi.broker; - public class SendOneRequest { private Session session; private Message message; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendOneResponse.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendOneResponse.java b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendOneResponse.java index bd129f4..7114758 100644 --- a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendOneResponse.java +++ b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendOneResponse.java @@ -16,6 +16,5 @@ */ package org.apache.openmessaging.wireapi.broker; - public class SendOneResponse { } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendOrderRequest.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendOrderRequest.java b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendOrderRequest.java index 05a7da5..d887c8c 100644 --- a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendOrderRequest.java +++ b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendOrderRequest.java @@ -16,7 +16,6 @@ */ package org.apache.openmessaging.wireapi.broker; - public class SendOrderRequest { private Message message; } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendOrderResponse.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendOrderResponse.java b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendOrderResponse.java index d2f6275..853d737 100644 --- a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendOrderResponse.java +++ b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/SendOrderResponse.java @@ -16,6 +16,5 @@ */ package org.apache.openmessaging.wireapi.broker; - public class SendOrderResponse { } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/Session.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/Session.java b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/Session.java index 9fc6054..978dbaa 100644 --- a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/Session.java +++ b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/Session.java @@ -16,7 +16,6 @@ */ package org.apache.openmessaging.wireapi.broker; - public class Session { private String sessionID; } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/Subscription.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/Subscription.java b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/Subscription.java index fe5e8c8..ec263c4 100644 --- a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/Subscription.java +++ b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/broker/Subscription.java @@ -16,6 +16,5 @@ */ package org.apache.openmessaging.wireapi.broker; - public class Subscription { } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/client/ClientCallbackWireAPI.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/client/ClientCallbackWireAPI.java b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/client/ClientCallbackWireAPI.java index 2cf09fb..6635644 100644 --- a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/client/ClientCallbackWireAPI.java +++ b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/client/ClientCallbackWireAPI.java @@ -16,7 +16,6 @@ */ package org.apache.openmessaging.wireapi.client; - public interface ClientCallbackWireAPI { void ping(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/consumer/ConsumerCallbackWireAPI.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/consumer/ConsumerCallbackWireAPI.java b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/consumer/ConsumerCallbackWireAPI.java index cdbd409..f88756b 100644 --- a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/consumer/ConsumerCallbackWireAPI.java +++ b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/consumer/ConsumerCallbackWireAPI.java @@ -18,7 +18,6 @@ package org.apache.openmessaging.wireapi.consumer; import org.apache.openmessaging.wireapi.client.ClientCallbackWireAPI; - public interface ConsumerCallbackWireAPI extends ClientCallbackWireAPI { void push(); } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/consumer/ConsumerSelfWireAPI.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/consumer/ConsumerSelfWireAPI.java b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/consumer/ConsumerSelfWireAPI.java index 019cb9f..47b7677 100644 --- a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/consumer/ConsumerSelfWireAPI.java +++ b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/consumer/ConsumerSelfWireAPI.java @@ -16,7 +16,6 @@ */ package org.apache.openmessaging.wireapi.consumer; - public interface ConsumerSelfWireAPI { void forward(); } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/naming/MetaServiceWireAPI.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/naming/MetaServiceWireAPI.java b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/naming/MetaServiceWireAPI.java index ac24098..89f89da 100644 --- a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/naming/MetaServiceWireAPI.java +++ b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/naming/MetaServiceWireAPI.java @@ -16,7 +16,6 @@ */ package org.apache.openmessaging.wireapi.naming; - public interface MetaServiceWireAPI { void createTopic(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/naming/NameClientReadWireAPI.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/naming/NameClientReadWireAPI.java b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/naming/NameClientReadWireAPI.java index 2771a4f..62b6628 100644 --- a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/naming/NameClientReadWireAPI.java +++ b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/naming/NameClientReadWireAPI.java @@ -16,6 +16,5 @@ */ package org.apache.openmessaging.wireapi.naming; - public interface NameClientReadWireAPI { } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/naming/NameClientWriteWireAPI.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/naming/NameClientWriteWireAPI.java b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/naming/NameClientWriteWireAPI.java index f853231..c0ad396 100644 --- a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/naming/NameClientWriteWireAPI.java +++ b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/naming/NameClientWriteWireAPI.java @@ -16,6 +16,5 @@ */ package org.apache.openmessaging.wireapi.naming; - public interface NameClientWriteWireAPI { } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/554d30aa/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/producer/ProducerCallbackWireAPI.java ---------------------------------------------------------------------- diff --git a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/producer/ProducerCallbackWireAPI.java b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/producer/ProducerCallbackWireAPI.java index b2376cf..14dc33b 100644 --- a/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/producer/ProducerCallbackWireAPI.java +++ b/spec/code/messaging-wire-level-api/src/main/java/org/apache/openmessaging/wireapi/producer/ProducerCallbackWireAPI.java @@ -18,7 +18,6 @@ package org.apache.openmessaging.wireapi.producer; import org.apache.openmessaging.wireapi.client.ClientCallbackWireAPI; - public interface ProducerCallbackWireAPI extends ClientCallbackWireAPI { void checkTransactionState(); }
