You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by vi...@apache.org on 2016/12/30 09:00:43 UTC
[2/4] incubator-rocketmq git commit: [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
[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 <vi...@apache.org>
Authored: Thu Dec 29 11:03:49 2016 +0800
Committer: vintagewang <vi...@apache.org>
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();
}