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:42 UTC
[1/4] incubator-rocketmq git commit: [ROCKETMQ-17] Develop a
vendor-neutral open standard for distributed messaging: add exception ASF
JIRA: https://issues.apache.org/jira/browse/ROCKETMQ-17
Repository: incubator-rocketmq
Updated Branches:
refs/heads/spec b39f6c9fd -> 3735a3f4d
[ROCKETMQ-17] Develop a vendor-neutral open standard for distributed messaging: add exception
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/2f14f71e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/2f14f71e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/2f14f71e
Branch: refs/heads/spec
Commit: 2f14f71e440aa00588f6288619d708b9db8b3ed2
Parents: b39f6c9
Author: vintagewang <vi...@apache.org>
Authored: Thu Dec 29 11:02:06 2016 +0800
Committer: vintagewang <vi...@apache.org>
Committed: Thu Dec 29 11:02:06 2016 +0800
----------------------------------------------------------------------
.../org/apache/openmessaging/MessageHeader.java | 32 +++++++++++++++++++
.../openmessaging/MessageHeaderConst.java | 33 --------------------
.../openmessaging/exception/OMSException.java | 20 ++++++++++++
.../exception/OMSRuntimeException.java | 21 +++++++++++++
4 files changed, 73 insertions(+), 33 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2f14f71e/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeader.java
----------------------------------------------------------------------
diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeader.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeader.java
new file mode 100644
index 0000000..82257fc
--- /dev/null
+++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeader.java
@@ -0,0 +1,32 @@
+/**
+ * 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.openmessaging;
+
+public class MessageHeader {
+ public static final String MessageId = "MessageId";
+ public static final String Topic = "Topic";
+ public static final String BornTimestamp = "BornTimestamp";
+ public static final String BornHost = "BornHost";
+ public static final String StoreTimestamp = "StoreTimestamp";
+ public static final String StoreHost = "StoreHost";
+ public static final String StartTime = "StartTime";
+ public static final String StopTime = "StopTime";
+ public static final String Timeout = "Timeout";
+ public static final String Priority = "Priority";
+ public static final String Reliability = "Reliability";
+ public static final String SearchKey = "SearchKey";
+}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2f14f71e/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeaderConst.java
----------------------------------------------------------------------
diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeaderConst.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeaderConst.java
deleted file mode 100644
index a0d10e2..0000000
--- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeaderConst.java
+++ /dev/null
@@ -1,33 +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.openmessaging;
-
-
-public class MessageHeaderConst {
- public static final String OMSTopic = "OMSTopic";
- public static final String OMSBornTimestamp = "OMSBornTimestamp";
- public static final String OMSBornHost = "OMSBornHost";
- public static final String OMSStoreTimestamp = "OMSStoreTimestamp";
- public static final String OMSStoreHost = "OMSStoreHost";
- public static final String OMSStartTime = "OMSStartTime";
- public static final String OMSStopTime = "OMSStopTime";
- public static final String OMSTimeout = "OMSTimeout";
- public static final String OMSPriority = "OMSPriority";
- public static final String OMSReliability = "OMSReliability";
- public static final String OMSSearchKey = "OMSSearchKey";
- public static final String OMSMsgId = "OMSMsgId";
-}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2f14f71e/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSException.java
----------------------------------------------------------------------
diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSException.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSException.java
new file mode 100644
index 0000000..de134b9
--- /dev/null
+++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSException.java
@@ -0,0 +1,20 @@
+/**
+ * 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.openmessaging.exception;
+
+public class OMSException extends Exception {
+}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2f14f71e/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
new file mode 100644
index 0000000..ee38600
--- /dev/null
+++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSRuntimeException.java
@@ -0,0 +1,21 @@
+/**
+ * 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.openmessaging.exception;
+
+public class OMSRuntimeException extends RuntimeException {
+}
[3/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 and update copyright ASF JIRA:
https://issues.apache.org/jira/browse/ROCKETMQ-17
Posted by vi...@apache.org.
[ROCKETMQ-17] Develop a vendor-neutral open standard for distributed messaging: reformat code as new code style /style/rmq_codeStyle.xml and update copyright
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/53eda1a1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/53eda1a1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/53eda1a1
Branch: refs/heads/spec
Commit: 53eda1a115f72dfceb12b7bfb9eed0df16c79c94
Parents: 554d30a
Author: vintagewang <vi...@apache.org>
Authored: Thu Dec 29 11:17:37 2016 +0800
Committer: vintagewang <vi...@apache.org>
Committed: Thu Dec 29 11:17:37 2016 +0800
----------------------------------------------------------------------
.../java/org/apache/openmessaging/BytesMessage.java | 14 +++++++-------
.../main/java/org/apache/openmessaging/KeyValue.java | 14 +++++++-------
.../main/java/org/apache/openmessaging/Message.java | 14 +++++++-------
.../java/org/apache/openmessaging/MessageFactory.java | 14 +++++++-------
.../java/org/apache/openmessaging/MessageHeader.java | 14 +++++++-------
.../org/apache/openmessaging/MessagingEndPoint.java | 14 +++++++-------
.../openmessaging/MessagingEndPointManager.java | 14 +++++++-------
.../main/java/org/apache/openmessaging/Producer.java | 14 +++++++-------
.../java/org/apache/openmessaging/PullConsumer.java | 14 +++++++-------
.../java/org/apache/openmessaging/PushConsumer.java | 14 +++++++-------
.../apache/openmessaging/exception/OMSException.java | 14 +++++++-------
.../openmessaging/exception/OMSRuntimeException.java | 14 +++++++-------
.../internal/MessagingEndPointAdapter.java | 10 +++++-----
.../internal/MessagingEndPointFactory.java | 10 +++++-----
.../openmessaging/internal/ServiceConstants.java | 10 +++++-----
.../apache/openmessaging/internal/URISpecParser.java | 10 +++++-----
.../org/apache/openmessaging/samples/ProducerApp.java | 14 +++++++-------
.../wireapi/broker/BrokerAdminWireAPI.java | 14 +++++++-------
.../wireapi/broker/BrokerConsumeWireAPI.java | 14 +++++++-------
.../wireapi/broker/BrokerProduceWireAPI.java | 14 +++++++-------
.../openmessaging/wireapi/broker/ConnectRequest.java | 14 +++++++-------
.../apache/openmessaging/wireapi/broker/Message.java | 14 +++++++-------
.../wireapi/broker/SendBatchRequest.java | 14 +++++++-------
.../wireapi/broker/SendBatchResponse.java | 14 +++++++-------
.../openmessaging/wireapi/broker/SendOneRequest.java | 14 +++++++-------
.../openmessaging/wireapi/broker/SendOneResponse.java | 14 +++++++-------
.../wireapi/broker/SendOrderRequest.java | 14 +++++++-------
.../wireapi/broker/SendOrderResponse.java | 14 +++++++-------
.../apache/openmessaging/wireapi/broker/Session.java | 14 +++++++-------
.../openmessaging/wireapi/broker/Subscription.java | 14 +++++++-------
.../wireapi/client/ClientCallbackWireAPI.java | 14 +++++++-------
.../wireapi/consumer/ConsumerCallbackWireAPI.java | 14 +++++++-------
.../wireapi/consumer/ConsumerSelfWireAPI.java | 14 +++++++-------
.../wireapi/naming/MetaServiceWireAPI.java | 14 +++++++-------
.../wireapi/naming/NameClientReadWireAPI.java | 14 +++++++-------
.../wireapi/naming/NameClientWriteWireAPI.java | 14 +++++++-------
.../wireapi/producer/ProducerCallbackWireAPI.java | 14 +++++++-------
37 files changed, 251 insertions(+), 251 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 32fed47..0829c6c 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 0b5f275..b75c424 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 589fa0b..fb78ddf 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 669153b..fa508e5 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeader.java
----------------------------------------------------------------------
diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeader.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeader.java
index 82257fc..13cfe4e 100644
--- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeader.java
+++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageHeader.java
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 b95423f..4eb5693 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 bb70ff4..a89d69a 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 35d90d4..48a154a 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 27c4279..d2fe24c 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 86025e4..78ea718 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSException.java
----------------------------------------------------------------------
diff --git a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSException.java b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSException.java
index de134b9..37f13e9 100644
--- a/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSException.java
+++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/exception/OMSException.java
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.exception;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 c10c47b..459e3ca 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.exception;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 8c79b3c..5b2adca 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
@@ -8,11 +8,11 @@
*
* 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.
+ * 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.openmessaging.internal;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 c3c963c..22af260 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
@@ -8,11 +8,11 @@
*
* 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.
+ * 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.openmessaging.internal;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 19c4057..74af998 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
@@ -8,11 +8,11 @@
*
* 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.
+ * 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.openmessaging.internal;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 8a69c0b..ab5e67d 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
@@ -8,11 +8,11 @@
*
* 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.
+ * 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.openmessaging.internal;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 16f6b3f..897365a 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.samples;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 e71289e..d5f6c17 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.wireapi.broker;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 b96d5a8..130e673 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.wireapi.broker;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 f8a2424..1c7d85e 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.wireapi.broker;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 0f436a3..d41a1d0 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.wireapi.broker;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 aecb963..b12e69d 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.wireapi.broker;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 ed59f69..2ef4f11 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.wireapi.broker;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 e17a29e..cb15e70 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.wireapi.broker;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 7645fb0..8a2ac88 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.wireapi.broker;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 7114758..3267ac8 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.wireapi.broker;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 d887c8c..a1ef49b 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.wireapi.broker;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 853d737..115a30d 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.wireapi.broker;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 978dbaa..9060b26 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.wireapi.broker;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 ec263c4..19a1ee9 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.wireapi.broker;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 6635644..2db2411 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.wireapi.client;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 f88756b..03eb640 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.wireapi.consumer;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 47b7677..58cc761 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.wireapi.consumer;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 89f89da..f5d23e1 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.wireapi.naming;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 62b6628..62506aa 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.wireapi.naming;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 c0ad396..2c1b526 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.wireapi.naming;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/53eda1a1/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 14dc33b..90d52ef 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
@@ -1,4 +1,4 @@
-/**
+/*
* 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.
@@ -6,13 +6,13 @@
* (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
+ * 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.
+ * 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.openmessaging.wireapi.producer;
[4/4] incubator-rocketmq git commit: [ROCKETMQ-17] Develop a
vendor-neutral open standard for distributed messaging: add messaging relay
service standard ASF JIRA: https://issues.apache.org/jira/browse/ROCKETMQ-17
Posted by vi...@apache.org.
[ROCKETMQ-17] Develop a vendor-neutral open standard for distributed messaging: add messaging relay service standard
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/3735a3f4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/3735a3f4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/3735a3f4
Branch: refs/heads/spec
Commit: 3735a3f4db44849d3d0b12970b1f64b7d277d675
Parents: 53eda1a
Author: vintagewang <vi...@apache.org>
Authored: Fri Dec 30 17:00:19 2016 +0800
Committer: vintagewang <vi...@apache.org>
Committed: Fri Dec 30 17:00:19 2016 +0800
----------------------------------------------------------------------
spec/code/pom.xml | 10 +-
.../org/apache/openrelay/InvokeContext.java | 21 +++
.../java/org/apache/openrelay/KeyValue.java | 36 +++++
.../org/apache/openrelay/ServiceEndPoint.java | 95 +++++++++++++
.../openrelay/ServiceEndPointManager.java | 35 +++++
.../org/apache/openrelay/ServiceLifecycle.java | 24 ++++
.../apache/openrelay/ServiceLoadBalance.java | 33 +++++
.../org/apache/openrelay/ServiceProperties.java | 32 +++++
.../internal/ServiceEndPointAdapter.java | 132 +++++++++++++++++++
.../org/apache/openrelay/observer/Observer.java | 39 ++++++
10 files changed, 455 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/3735a3f4/spec/code/pom.xml
----------------------------------------------------------------------
diff --git a/spec/code/pom.xml b/spec/code/pom.xml
index 097431b..ec66577 100644
--- a/spec/code/pom.xml
+++ b/spec/code/pom.xml
@@ -13,6 +13,7 @@
<module>messaging-user-level-api/java</module>
<module>messaging-user-level-samples/java</module>
<module>messaging-wire-level-api</module>
+ <module>relay-user-level-api/java</module>
</modules>
<build>
@@ -22,8 +23,8 @@
<artifactId>maven-compiler-plugin</artifactId>
<version>2.3.2</version>
<configuration>
- <source>1.6</source>
- <target>1.6</target>
+ <source>1.7</source>
+ <target>1.7</target>
<encoding>UTF-8</encoding>
<showDeprecation>true</showDeprecation>
<showWarnings>true</showWarnings>
@@ -101,6 +102,11 @@
<version>${project.version}</version>
</dependency>
<dependency>
+ <groupId>${project.groupId}</groupId>
+ <artifactId>relay-user-level-api</artifactId>
+ <version>${project.version}</version>
+ </dependency>
+ <dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.11</version>
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/3735a3f4/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/InvokeContext.java
----------------------------------------------------------------------
diff --git a/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/InvokeContext.java b/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/InvokeContext.java
new file mode 100644
index 0000000..84c987d
--- /dev/null
+++ b/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/InvokeContext.java
@@ -0,0 +1,21 @@
+/*
+ * 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.openrelay;
+
+public interface InvokeContext {
+ KeyValue properties();
+}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/3735a3f4/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/KeyValue.java
----------------------------------------------------------------------
diff --git a/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/KeyValue.java b/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/KeyValue.java
new file mode 100644
index 0000000..b79023c
--- /dev/null
+++ b/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/KeyValue.java
@@ -0,0 +1,36 @@
+/*
+ * 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.openrelay;
+
+public interface KeyValue {
+ KeyValue put(final String key, final int value);
+
+ KeyValue put(final String key, final long value);
+
+ KeyValue put(final String key, final double value);
+
+ KeyValue put(final String key, final String value);
+
+ int getInt(final String key);
+
+ long getLong(final String key);
+
+ double getDouble(final String key);
+
+ String getString(final String key);
+}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/3735a3f4/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/ServiceEndPoint.java
----------------------------------------------------------------------
diff --git a/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/ServiceEndPoint.java b/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/ServiceEndPoint.java
new file mode 100644
index 0000000..f48f93e
--- /dev/null
+++ b/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/ServiceEndPoint.java
@@ -0,0 +1,95 @@
+/*
+ * 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.openrelay;
+
+import java.util.Properties;
+import org.apache.openrelay.observer.Observer;
+
+public interface ServiceEndPoint extends ServiceLifecycle {
+ /**
+ * Register/re-register a service in a serviceEndPoint object
+ * if service has been registered in serviceEndPoint object, it will be failed when registering delicately
+ *
+ * @param service the service to publish in serviceEndPoint
+ */
+ void publish(Object service);
+
+ /**
+ * Like {@link #publish(Object)} but specifying {@code properties}
+ * that can be used to configure the service published
+ *
+ * @param service the service to publish in serviceEndPoint
+ * @param properties the service published properties
+ */
+
+ void publish(Object service, Properties properties);
+
+ /**
+ * Bind a service object to serviceEndPoint, which can directly call services provided by service object
+ *
+ * @param type service type to bind in serviceEndPoint
+ * @return service proxy object to bind
+ */
+ <T> T bind(Class<T> type);
+
+ /**
+ * Like {@link #bind(Class)} but specifying {@code properties} that can be used to configure the service band
+ *
+ * @param type service type to bind in serviceEndPoint
+ * @param properties the service bind properties
+ * @param <T> service proxy object to bind
+ * @return service proxy object to bind
+ */
+ <T> T bind(Class<T> type, Properties properties);
+
+ /**
+ * Like {@link #bind(Class, Properties)} but specifying {@code serviceLoadBalance} that can be used to select
+ * endPoint target
+ *
+ * @param type service type to bind in serviceConsumer
+ * @param properties the service band properties
+ * @param serviceLoadBalance select endPoint target algorithm
+ * @param <T> service proxy object to bind
+ * @return service proxy object to bind
+ */
+ <T> T bind(Class<T> type, Properties properties, ServiceLoadBalance serviceLoadBalance);
+
+ /**
+ * Register an observer in an serviceEndPoint object. Whenever serviceEndPoint object publish or bind an service
+ * object, it will be notified to the list of observer object registered before
+ *
+ * @param observer observer event object to an serviceEndPoint object
+ */
+ void addObserver(Observer observer);
+
+ /**
+ * Removes the given observer from the list of observer
+ * <p>
+ * If the given observer has not been previously registered (i.e. it was
+ * never added) then this method call is a no-op. If it had been previously
+ * added then it will be removed. If it had been added more than once, then
+ * only the first occurrence will be removed.
+ *
+ * @param observer The observer to remove
+ */
+ void deleteObserver(Observer observer);
+
+ /**
+ * @return
+ */
+ InvokeContext invokeContext();
+}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/3735a3f4/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/ServiceEndPointManager.java
----------------------------------------------------------------------
diff --git a/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/ServiceEndPointManager.java b/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/ServiceEndPointManager.java
new file mode 100644
index 0000000..49e07ab
--- /dev/null
+++ b/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/ServiceEndPointManager.java
@@ -0,0 +1,35 @@
+/*
+ * 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.openrelay;
+
+import org.apache.openrelay.internal.ServiceEndPointAdapter;
+
+public class ServiceEndPointManager {
+ public static ServiceEndPoint getServiceEndPoint(String url) throws Exception {
+ return getServiceEndPoint(url, null);
+ }
+
+ public static ServiceEndPoint getServiceEndPoint(String url, KeyValue properties) throws Exception {
+ return ServiceEndPointAdapter.createServiceEndPoint(url, properties);
+ }
+
+ public static KeyValue buildKeyValue() {
+ return null;
+ }
+}
+
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/3735a3f4/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/ServiceLifecycle.java
----------------------------------------------------------------------
diff --git a/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/ServiceLifecycle.java b/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/ServiceLifecycle.java
new file mode 100644
index 0000000..d0c82af
--- /dev/null
+++ b/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/ServiceLifecycle.java
@@ -0,0 +1,24 @@
+/*
+ * 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.openrelay;
+
+public interface ServiceLifecycle {
+ void start();
+
+ void stop();
+}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/3735a3f4/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/ServiceLoadBalance.java
----------------------------------------------------------------------
diff --git a/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/ServiceLoadBalance.java b/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/ServiceLoadBalance.java
new file mode 100644
index 0000000..9c4bd17
--- /dev/null
+++ b/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/ServiceLoadBalance.java
@@ -0,0 +1,33 @@
+/*
+ * 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.openrelay;
+
+import java.util.Set;
+
+public interface ServiceLoadBalance {
+ /**
+ * Select a collection of eligible providerServicePoint object from the the list of providerServicePoint provided
+ * According to different selection strategies to select providerServicePoint that satisfied with application needs,
+ * such as RoundRobin or Random etc.
+ *
+ * @param servicePropertiesList providerServicePoint to choose from.
+ * @return a collection of eligible providerServicePoint object
+ */
+ Set<ServiceProperties> select(Set<ServiceProperties> servicePropertiesList);
+
+}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/3735a3f4/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/ServiceProperties.java
----------------------------------------------------------------------
diff --git a/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/ServiceProperties.java b/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/ServiceProperties.java
new file mode 100644
index 0000000..423abd8
--- /dev/null
+++ b/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/ServiceProperties.java
@@ -0,0 +1,32 @@
+/*
+ * 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.openrelay;
+
+public interface ServiceProperties {
+ String id();
+
+ void id(String id);
+
+ String relayAddress();
+
+ void relayAddress(String address);
+
+ String providerId();
+
+ void providerId(String id);
+}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/3735a3f4/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/internal/ServiceEndPointAdapter.java
----------------------------------------------------------------------
diff --git a/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/internal/ServiceEndPointAdapter.java b/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/internal/ServiceEndPointAdapter.java
new file mode 100644
index 0000000..06ce69a
--- /dev/null
+++ b/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/internal/ServiceEndPointAdapter.java
@@ -0,0 +1,132 @@
+/*
+ * 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.openrelay.internal;
+
+import java.lang.reflect.Constructor;
+import java.lang.reflect.InvocationTargetException;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Properties;
+import org.apache.openrelay.KeyValue;
+import org.apache.openrelay.ServiceEndPoint;
+
+public class ServiceEndPointAdapter {
+ private static final String PROTOCOL_NAME = "protocol";
+ private static final String SPI_NAME = "spi";
+ private static final String URL_NAME = "urls";
+ private static final String URL = "url";
+ private static final String DEFAULT_SERVICE_END_POINT = "rocketmq";
+ private static final String DEFAULT_SERVICE_IMPL = "org.apache.rocketmq.openrelay.impl.ServiceEndPointStandardImpl";
+ private static final String URL_SEPARATOR = ":";
+ private static final String LIST_SEPARATOR = ",";
+ private static final String PARAM_SEPARATOR = "&";
+ private static final String KV_SEPARATOR = "=";
+ private static Map<String, String> serviceEndPointClassMap = new HashMap<>();
+
+ static {
+ serviceEndPointClassMap.put(DEFAULT_SERVICE_END_POINT, DEFAULT_SERVICE_IMPL);
+ }
+
+ private static Map<String, List<String>> parseURI(String uri) {
+ if (uri == null || uri.length() == 0) {
+ return new HashMap<>();
+ }
+
+ int spiIndex = 0;
+ int index = uri.indexOf(URL_SEPARATOR);
+ Map<String, List<String>> results = new HashMap<>();
+ String protocol = uri.substring(0, index);
+ List<String> protocolSet = new ArrayList<>();
+ protocolSet.add(protocol);
+ results.put(PROTOCOL_NAME, protocolSet);
+ if (index > 0) {
+ String spi;
+ spiIndex = uri.indexOf(URL_SEPARATOR, index + 1);
+ if (spiIndex > 0) {
+ spi = uri.substring(index + 1, spiIndex);
+ }
+ else {
+ spi = uri.substring(index + 1);
+ }
+ List<String> spiSet = new ArrayList<>();
+ spiSet.add(spi);
+ results.put(SPI_NAME, spiSet);
+ }
+ if (spiIndex > 0) {
+ String urlList = uri.substring(spiIndex + 1);
+ String[] list = urlList.split(LIST_SEPARATOR);
+ if (list.length > 0) {
+ results.put(URL_NAME, Arrays.asList(list));
+ }
+ }
+ return results;
+ }
+
+ private static ServiceEndPoint instantiateServiceEndPoint(String driver, KeyValue properties)
+ throws ClassNotFoundException, NoSuchMethodException, IllegalAccessException,
+ InvocationTargetException, InstantiationException {
+ String serviceImpl = driver;
+ if (serviceImpl == null)
+ serviceImpl = DEFAULT_SERVICE_IMPL;
+ if (serviceEndPointClassMap.containsKey(driver))
+ serviceImpl = serviceEndPointClassMap.get(driver);
+ Class<?> serviceEndPointClass = Class.forName(serviceImpl);
+ if (serviceEndPointClass == null)
+ return null;
+
+ if (properties.getString(URL) != null) {
+ String[] propertySplits = ((String)properties.getString(URL)).split(PARAM_SEPARATOR);
+ if (propertySplits.length > 0) {
+ for (int index = 1; index < propertySplits.length; index++) {
+ String[] kv = propertySplits[index].split(KV_SEPARATOR);
+ properties.put(kv[0], kv[1]);
+ }
+ }
+ }
+ Class[] paramTypes = {Properties.class};
+ Constructor constructor = serviceEndPointClass.getConstructor(paramTypes);
+ assert constructor != null;
+ return (ServiceEndPoint)constructor.newInstance(properties);
+ }
+
+ private static ServiceEndPoint createServiceEndPoint(Map<String, List<String>> url, KeyValue properties)
+ throws ClassNotFoundException, NoSuchMethodException, InvocationTargetException,
+ InstantiationException, IllegalAccessException {
+ List<String> driver = url.get(SPI_NAME);
+ List<String> urls = url.get(URL_NAME);
+ Collections.shuffle(urls);
+ Collections.shuffle(driver);
+ if (urls.size() > 0)
+ properties.put(URL, urls.get(0));
+ return ServiceEndPointAdapter.instantiateServiceEndPoint(driver.get(0), properties);
+ }
+
+ public static ServiceEndPoint createServiceEndPoint(String url, KeyValue properties)
+ throws ClassNotFoundException, NoSuchMethodException, InstantiationException,
+ IllegalAccessException, InvocationTargetException {
+ Map<String, List<String>> driverUrl = parseURI(url);
+ if (null == driverUrl || driverUrl.size() == 0) {
+ throw new IllegalArgumentException("driver url parsed result.size ==0");
+ }
+ return createServiceEndPoint(driverUrl, properties);
+ }
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/3735a3f4/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/observer/Observer.java
----------------------------------------------------------------------
diff --git a/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/observer/Observer.java b/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/observer/Observer.java
new file mode 100644
index 0000000..097d309
--- /dev/null
+++ b/spec/code/relay-user-level-api/java/src/main/java/org/apache/openrelay/observer/Observer.java
@@ -0,0 +1,39 @@
+/*
+ * 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.openrelay.observer;
+
+import java.util.Observable;
+
+public interface Observer<T> {
+ /**
+ * Notifies the Observer that the {@link Observable} has finished sending push-based notifications.
+ * <p>
+ * The {@link Observable} will not call this method if it calls {@link #onError}.
+ */
+ void onCompleted();
+
+ /**
+ * Notifies the Observer that the {@link Observable} has experienced an error condition.
+ * <p>
+ * If the {@link Observable} calls this method, it will not thereafter call
+ * {@link #onCompleted}.
+ *
+ * @param e the exception encountered by the Observable
+ */
+ void onError(Throwable e);
+}
[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
Posted by vi...@apache.org.
[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();
}