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/28 07:57:39 UTC
[1/5] incubator-rocketmq git commit: [ROCKETMQ-17] Develop a
vendor-neutral open standard for distributed messaging: remove author
annotation https://issues.apache.org/jira/browse/ROCKETMQ-17
Repository: incubator-rocketmq
Updated Branches:
refs/heads/spec 13cba1884 -> 58acef9ef
[ROCKETMQ-17] Develop a vendor-neutral open standard for distributed messaging: remove author annotation
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/2c3121b7
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/2c3121b7
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/2c3121b7
Branch: refs/heads/spec
Commit: 2c3121b7f2164a3f6afadbe4bc5083d6db018efc
Parents: 13cba18
Author: vintagewang <vi...@apache.org>
Authored: Wed Dec 28 14:14:59 2016 +0800
Committer: vintagewang <vi...@apache.org>
Committed: Wed Dec 28 14:14:59 2016 +0800
----------------------------------------------------------------------
.../src/main/java/org/apache/openmessaging/BytesMessage.java | 5 +----
.../java/src/main/java/org/apache/openmessaging/Message.java | 3 ---
.../main/java/org/apache/openmessaging/MessagingEndPoint.java | 5 +----
.../java/org/apache/openmessaging/MessagingEndPointManager.java | 5 +----
.../java/src/main/java/org/apache/openmessaging/Producer.java | 4 +---
.../src/main/java/org/apache/openmessaging/PullConsumer.java | 4 +---
.../src/main/java/org/apache/openmessaging/PushConsumer.java | 4 +---
.../apache/openmessaging/internal/MessagingEndPointAdapter.java | 5 +----
.../apache/openmessaging/internal/MessagingEndPointFactory.java | 5 +----
.../org/apache/openmessaging/internal/ServiceConstants.java | 5 +----
.../java/org/apache/openmessaging/internal/URISpecParser.java | 5 +----
.../apache/openmessaging/wireapi/broker/BrokerAdminWireAPI.java | 5 +----
.../openmessaging/wireapi/broker/BrokerConsumeWireAPI.java | 5 +----
.../openmessaging/wireapi/broker/BrokerProduceWireAPI.java | 5 +----
.../org/apache/openmessaging/wireapi/broker/ConnectRequest.java | 5 +----
.../java/org/apache/openmessaging/wireapi/broker/Message.java | 5 +----
.../apache/openmessaging/wireapi/broker/SendBatchRequest.java | 5 +----
.../apache/openmessaging/wireapi/broker/SendBatchResponse.java | 5 +----
.../org/apache/openmessaging/wireapi/broker/SendOneRequest.java | 5 +----
.../apache/openmessaging/wireapi/broker/SendOneResponse.java | 5 +----
.../apache/openmessaging/wireapi/broker/SendOrderRequest.java | 5 +----
.../apache/openmessaging/wireapi/broker/SendOrderResponse.java | 5 +----
.../java/org/apache/openmessaging/wireapi/broker/Session.java | 5 +----
.../org/apache/openmessaging/wireapi/broker/Subscription.java | 5 +----
.../openmessaging/wireapi/client/ClientCallbackWireAPI.java | 5 +----
.../openmessaging/wireapi/consumer/ConsumerCallbackWireAPI.java | 5 +----
.../openmessaging/wireapi/consumer/ConsumerSelfWireAPI.java | 5 +----
.../apache/openmessaging/wireapi/naming/MetaServiceWireAPI.java | 5 +----
.../openmessaging/wireapi/naming/NameClientReadWireAPI.java | 5 +----
.../openmessaging/wireapi/naming/NameClientWriteWireAPI.java | 5 +----
.../openmessaging/wireapi/producer/ProducerCallbackWireAPI.java | 5 +----
31 files changed, 30 insertions(+), 120 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 ac279da..47e18d4 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
@@ -14,12 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging;
-/**
- * @author vintagewang@apache.org
- */
+
public interface BytesMessage extends Message {
byte[] getBody();
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 4339227..9e8c6be 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
@@ -17,9 +17,6 @@
package org.apache.openmessaging;
-/**
- * @author vintagewang@apache.org
- */
public interface Message {
Message putHeader(final String name, final String value);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 f90cb62..12fa172 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
@@ -14,12 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging;
-/**
- * @author vintagewang@apache.org
- */
+
public interface MessagingEndPoint {
void start();
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 0ecd870..39c202d 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
@@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging;
import org.apache.openmessaging.internal.MessagingEndPointFactory;
@@ -24,9 +23,7 @@ import java.util.List;
import java.util.Map;
import java.util.Properties;
-/**
- * @author vintagewang@apache.org
- */
+
public class MessagingEndPointManager {
public static MessagingEndPoint getMessagingEndPoint(String url) {
return getMessagingEndPoint(url, new Properties());
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 91ed147..a8fc70d 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,9 +16,7 @@
*/
package org.apache.openmessaging;
-/**
- * @author vintagewang@apache.org
- */
+
public interface Producer {
void start();
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 66222ec..fa65543 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,9 +16,7 @@
*/
package org.apache.openmessaging;
-/**
- * @author vintagewang@apache.org
- */
+
public interface PullConsumer {
}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 f12c291..d27cab8 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,9 +16,7 @@
*/
package org.apache.openmessaging;
-/**
- * @author vintagewang@apache.org
- */
+
public interface PushConsumer {
}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 9b2835d..f5f2711 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
@@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.internal;
@@ -26,9 +25,7 @@ import java.util.HashMap;
import java.util.Map;
import java.util.Properties;
-/**
- * @author vintagewang@apache.org
- */
+
class MessagingEndPointAdapter {
private static Map<String, String> serviceEndPointClassMap = new HashMap<String, String>();
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 1dbc71d..ea1a395 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
@@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.internal;
import org.apache.openmessaging.MessagingEndPoint;
@@ -23,9 +22,7 @@ import java.util.List;
import java.util.Map;
import java.util.Properties;
-/**
- * @author vintagewang@apache.org
- */
+
public class MessagingEndPointFactory {
public static MessagingEndPoint createMessagingEndPoint(Map<String, List<String>> url, Properties properties) {
List<String> driver = url.get(ServiceConstants.SPI_NAME);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 f445a9c..7fc899f 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
@@ -14,12 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.internal;
-/**
- * @author vintagewang@apache.org
- */
+
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/2c3121b7/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 0b6feac..d2ec999 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
@@ -14,7 +14,6 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.internal;
import java.util.ArrayList;
@@ -23,9 +22,7 @@ import java.util.HashMap;
import java.util.List;
import java.util.Map;
-/**
- * @author vintagewang@apache.org
- */
+
public class URISpecParser {
public static Map<String, List<String>> parseURI(String uri) {
if (uri == null || uri.length() == 0) {
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 33841b8..a57d5d5 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
@@ -14,11 +14,8 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.wireapi.broker;
-/**
- * @author vintagewang@apache.org
- */
+
public interface BrokerAdminWireAPI {
}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 10a19fe..a8019e2 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
@@ -14,12 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.wireapi.broker;
-/**
- * @author vintagewang@apache.org
- */
+
public interface BrokerConsumeWireAPI {
Session connect(ConnectRequest request);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 4523c35..d5bb6b8 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
@@ -14,12 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.wireapi.broker;
-/**
- * @author vintagewang@apache.org
- */
+
public interface BrokerProduceWireAPI {
Session connect(ConnectRequest request);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 d6bd042..17ffd07 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
@@ -14,12 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.wireapi.broker;
-/**
- * @author vintagewang@apache.org
- */
+
public class ConnectRequest {
private String localHostIP;
private String authKey;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 b7037b9..a611b58 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
@@ -14,15 +14,12 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.wireapi.broker;
import java.util.Map;
-/**
- * @author vintagewang@apache.org
- */
+
public class Message {
private Map<String, String> systemHeader;
private Map<String, String> userHeader;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 10f722f..73a6542 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
@@ -14,12 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.wireapi.broker;
-/**
- * @author vintagewang@apache.org
- */
+
public class SendBatchRequest {
private Message message;
}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 bbeba60..3a70e64 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
@@ -14,11 +14,8 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.wireapi.broker;
-/**
- * @author vintagewang@apache.org
- */
+
public class SendBatchResponse {
}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 f1c868d..1b59463 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
@@ -14,12 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.wireapi.broker;
-/**
- * @author vintagewang@apache.org
- */
+
public class SendOneRequest {
private Session session;
private Message message;
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 1eeef75..bd129f4 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
@@ -14,11 +14,8 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.wireapi.broker;
-/**
- * @author vintagewang@apache.org
- */
+
public class SendOneResponse {
}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 13ce72c..05a7da5 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
@@ -14,12 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.wireapi.broker;
-/**
- * @author vintagewang@apache.org
- */
+
public class SendOrderRequest {
private Message message;
}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 507b1bb..d2f6275 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
@@ -14,11 +14,8 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.wireapi.broker;
-/**
- * @author vintagewang@apache.org
- */
+
public class SendOrderResponse {
}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 8da95d8..9fc6054 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
@@ -14,12 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.wireapi.broker;
-/**
- * @author vintagewang@apache.org
- */
+
public class Session {
private String sessionID;
}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 7bcac53..fe5e8c8 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
@@ -14,11 +14,8 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.wireapi.broker;
-/**
- * @author vintagewang@apache.org
- */
+
public class Subscription {
}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 dd1a555..2cf09fb 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
@@ -14,12 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.wireapi.client;
-/**
- * @author vintagewang@apache.org
- */
+
public interface ClientCallbackWireAPI {
void ping();
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 a7dbabb..cdbd409 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
@@ -14,14 +14,11 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.wireapi.consumer;
import org.apache.openmessaging.wireapi.client.ClientCallbackWireAPI;
-/**
- * @author vintagewang@apache.org
- */
+
public interface ConsumerCallbackWireAPI extends ClientCallbackWireAPI {
void push();
}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 60cb480..019cb9f 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
@@ -14,12 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.wireapi.consumer;
-/**
- * @author vintagewang@apache.org
- */
+
public interface ConsumerSelfWireAPI {
void forward();
}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 791689c..ac24098 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
@@ -14,12 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.wireapi.naming;
-/**
- * @author vintagewang@apache.org
- */
+
public interface MetaServiceWireAPI {
void createTopic();
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 afe5bf6..2771a4f 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
@@ -14,11 +14,8 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.wireapi.naming;
-/**
- * @author vintagewang@apache.org
- */
+
public interface NameClientReadWireAPI {
}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 c416c66..f853231 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
@@ -14,11 +14,8 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.wireapi.naming;
-/**
- * @author vintagewang@apache.org
- */
+
public interface NameClientWriteWireAPI {
}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/2c3121b7/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 8228d66..b2376cf 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
@@ -14,14 +14,11 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.apache.openmessaging.wireapi.producer;
import org.apache.openmessaging.wireapi.client.ClientCallbackWireAPI;
-/**
- * @author vintagewang@apache.org
- */
+
public interface ProducerCallbackWireAPI extends ClientCallbackWireAPI {
void checkTransactionState();
}
[3/5] incubator-rocketmq git commit: [ROCKETMQ-17] Develop a
vendor-neutral open standard for distributed messaging: rename Producer to
ProducerApp https://issues.apache.org/jira/browse/ROCKETMQ-17
Posted by vi...@apache.org.
[ROCKETMQ-17] Develop a vendor-neutral open standard for distributed messaging: rename Producer to ProducerApp
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/a6964048
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/a6964048
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/a6964048
Branch: refs/heads/spec
Commit: a696404879dd6c2a07b6c831383a98d08a67f8ea
Parents: 5668d25
Author: vintagewang <vi...@apache.org>
Authored: Wed Dec 28 14:42:54 2016 +0800
Committer: vintagewang <vi...@apache.org>
Committed: Wed Dec 28 14:42:54 2016 +0800
----------------------------------------------------------------------
.../apache/openmessaging/samples/Producer.java | 45 -------------------
.../openmessaging/samples/ProducerApp.java | 46 ++++++++++++++++++++
2 files changed, 46 insertions(+), 45 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/a6964048/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/Producer.java
----------------------------------------------------------------------
diff --git a/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/Producer.java b/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/Producer.java
deleted file mode 100644
index a8bbb5d..0000000
--- a/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/Producer.java
+++ /dev/null
@@ -1,45 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.openmessaging.samples;
-
-
-import org.apache.openmessaging.MessagingEndPoint;
-import org.apache.openmessaging.MessagingEndPointManager;
-
-import java.nio.charset.Charset;
-
-public class Producer {
- public static void main(String[] args) {
- final MessagingEndPoint messagingEndPoint = MessagingEndPointManager.getMessagingEndPoint("openmessaging:rocketmq://localhost:10911/namespace");
-
- final org.apache.openmessaging.Producer producer = messagingEndPoint.createProducer();
-
- messagingEndPoint.start();
-
- producer.start();
-
- producer.send(producer.createBytesMessage("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8"))));
-
- Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
- @Override
- public void run() {
- producer.shutdown();
- messagingEndPoint.shutdown();
- }
- }));
- }
-}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/a6964048/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
new file mode 100644
index 0000000..0182058
--- /dev/null
+++ b/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/ProducerApp.java
@@ -0,0 +1,46 @@
+/**
+ * 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.samples;
+
+
+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");
+
+ final Producer producer = messagingEndPoint.createProducer();
+
+ messagingEndPoint.start();
+
+ producer.start();
+
+ producer.send(producer.createBytesMessage("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8"))));
+
+ Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
+ @Override
+ public void run() {
+ producer.shutdown();
+ messagingEndPoint.shutdown();
+ }
+ }));
+ }
+}
\ No newline at end of file
[5/5] incubator-rocketmq git commit: [ROCKETMQ-17] Develop a
vendor-neutral open standard for distributed messaging: refactor message
class and add new class KeyValue 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: refactor message class and add new class KeyValue
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/58acef9e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/58acef9e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/58acef9e
Branch: refs/heads/spec
Commit: 58acef9ef9bf6be62918d7293af7bc8c962c6bfb
Parents: 9f232be
Author: vintagewang <vi...@apache.org>
Authored: Wed Dec 28 15:57:21 2016 +0800
Committer: vintagewang <vi...@apache.org>
Committed: Wed Dec 28 15:57:21 2016 +0800
----------------------------------------------------------------------
.../org/apache/openmessaging/BytesMessage.java | 12 ++++++++
.../java/org/apache/openmessaging/KeyValue.java | 32 ++++++++++++++++++++
.../java/org/apache/openmessaging/Message.java | 8 ++---
.../openmessaging/MessagingEndPointManager.java | 4 +++
.../java/org/apache/openmessaging/Producer.java | 2 +-
.../openmessaging/samples/ProducerApp.java | 8 +++--
6 files changed, 56 insertions(+), 10 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/58acef9e/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 47e18d4..629cca2 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
@@ -18,6 +18,18 @@ package org.apache.openmessaging;
public interface BytesMessage extends Message {
+ BytesMessage putHeader(final String key, final int value);
+
+ BytesMessage putHeader(final String key, final long value);
+
+ BytesMessage putHeader(final String key, final String value);
+
+ BytesMessage putProperties(final String key, final int value);
+
+ BytesMessage putProperties(final String key, final long value);
+
+ BytesMessage putProperties(final String key, final String value);
+
byte[] getBody();
void setBody(final byte[] body);
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/58acef9e/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
new file mode 100644
index 0000000..c3f44f5
--- /dev/null
+++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/KeyValue.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 interface KeyValue {
+ KeyValue put(final String key, final int value);
+
+ KeyValue put(final String key, final long value);
+
+ KeyValue put(final String key, final String value);
+
+ int getInt(final String key);
+
+ long getLong(final String key);
+
+ String getString(final String key);
+}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/58acef9e/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 9e8c6be..5563c46 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
@@ -18,11 +18,7 @@ package org.apache.openmessaging;
public interface Message {
- Message putHeader(final String name, final String value);
+ KeyValue headers();
- Message putProperty(final String name, final String value);
-
- String getHeader(final String name);
-
- String getProperty(final String name);
+ KeyValue properties();
}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/58acef9e/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 39c202d..8196658 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
@@ -36,4 +36,8 @@ public class MessagingEndPointManager {
}
return MessagingEndPointFactory.createMessagingEndPoint(driverUrl, properties);
}
+
+ public static KeyValue buildKeyValue() {
+ return null;
+ }
}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/58acef9e/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 c7a3020..05eb15c 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
@@ -22,5 +22,5 @@ public interface Producer extends MessageFactory {
void shutdown();
- void send(final Message message);
+ void send(final BytesMessage message);
}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/58acef9e/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 f820f3f..051fc22 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
@@ -30,8 +30,10 @@ public class ProducerApp {
final Producer producer = messagingEndPoint.createProducer();
messagingEndPoint.start();
+ System.out.println("messagingEndPoint startup OK");
producer.start();
+ System.out.println("producer startup OK");
Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
@Override
@@ -45,9 +47,9 @@ public class ProducerApp {
System.out.println("send first message OK");
producer.send(producer.createBytesMessage("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8")))
- .putProperty("KEY1", "value1")//
- .putProperty("KEY2", "value2")//
- .putProperty("KEY3", "value3")//
+ .putProperties("KEY1", "value1")//
+ .putProperties("KEY2", "value2")//
+ .putProperties("KEY3", "value3")//
);
System.out.println("send second message OK");
}
[4/5] incubator-rocketmq git commit: [ROCKETMQ-17] Develop a
vendor-neutral open standard for distributed messaging: refactor ProducerApp
class https://issues.apache.org/jira/browse/ROCKETMQ-17
Posted by vi...@apache.org.
[ROCKETMQ-17] Develop a vendor-neutral open standard for distributed messaging: refactor ProducerApp class
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/9f232be5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/9f232be5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/9f232be5
Branch: refs/heads/spec
Commit: 9f232be56dcd32df0176508782264c65c5da6fff
Parents: a696404
Author: vintagewang <vi...@apache.org>
Authored: Wed Dec 28 14:55:01 2016 +0800
Committer: vintagewang <vi...@apache.org>
Committed: Wed Dec 28 14:55:01 2016 +0800
----------------------------------------------------------------------
.../org/apache/openmessaging/samples/ProducerApp.java | 12 ++++++++++--
1 file changed, 10 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/9f232be5/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 0182058..f820f3f 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
@@ -33,8 +33,6 @@ public class ProducerApp {
producer.start();
- producer.send(producer.createBytesMessage("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8"))));
-
Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
@Override
public void run() {
@@ -42,5 +40,15 @@ public class ProducerApp {
messagingEndPoint.shutdown();
}
}));
+
+ producer.send(producer.createBytesMessage("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8"))));
+ System.out.println("send first message OK");
+
+ producer.send(producer.createBytesMessage("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8")))
+ .putProperty("KEY1", "value1")//
+ .putProperty("KEY2", "value2")//
+ .putProperty("KEY3", "value3")//
+ );
+ System.out.println("send second message OK");
}
}
\ No newline at end of file
[2/5] incubator-rocketmq git commit: [ROCKETMQ-17] Develop a
vendor-neutral open standard for distributed messaging: add MessageFactory
interface 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 MessageFactory interface
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/5668d250
Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/5668d250
Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/5668d250
Branch: refs/heads/spec
Commit: 5668d250e8c9c2f4da6cf2be00eed6f26f7b5543
Parents: 2c3121b
Author: vintagewang <vi...@apache.org>
Authored: Wed Dec 28 14:41:52 2016 +0800
Committer: vintagewang <vi...@apache.org>
Committed: Wed Dec 28 14:41:52 2016 +0800
----------------------------------------------------------------------
.../apache/openmessaging/MessageFactory.java | 22 ++++++++++++++++++++
.../apache/openmessaging/MessagingEndPoint.java | 2 --
.../java/org/apache/openmessaging/Producer.java | 2 +-
.../apache/openmessaging/samples/Producer.java | 5 ++++-
4 files changed, 27 insertions(+), 4 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/5668d250/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
new file mode 100644
index 0000000..94e8ecf
--- /dev/null
+++ b/spec/code/messaging-user-level-api/java/src/main/java/org/apache/openmessaging/MessageFactory.java
@@ -0,0 +1,22 @@
+/**
+ * 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 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/5668d250/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 12fa172..634f552 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
@@ -27,6 +27,4 @@ public interface MessagingEndPoint {
PushConsumer createPushConsumer();
PullConsumer createPullConsumer();
-
- BytesMessage createBytesMessage(final String topic, final byte[] body);
}
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/5668d250/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 a8fc70d..c7a3020 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
@@ -17,7 +17,7 @@
package org.apache.openmessaging;
-public interface Producer {
+public interface Producer extends MessageFactory {
void start();
void shutdown();
http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/5668d250/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/Producer.java
----------------------------------------------------------------------
diff --git a/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/Producer.java b/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/Producer.java
index 30a0d78..a8bbb5d 100644
--- a/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/Producer.java
+++ b/spec/code/messaging-user-level-samples/java/src/main/java/org/apache/openmessaging/samples/Producer.java
@@ -28,14 +28,17 @@ public class Producer {
final org.apache.openmessaging.Producer producer = messagingEndPoint.createProducer();
+ messagingEndPoint.start();
+
producer.start();
- producer.send(messagingEndPoint.createBytesMessage("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8"))));
+ producer.send(producer.createBytesMessage("HELLO_TOPIC", "HELLO_BODY".getBytes(Charset.forName("UTF-8"))));
Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
@Override
public void run() {
producer.shutdown();
+ messagingEndPoint.shutdown();
}
}));
}