Repository: incubator-rocketmq Updated Branches: refs/heads/spec 92454311e -> 65afe5614
Develop a vendor-neutral open standard for distributed messaging: remove since Project: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/commit/65afe561 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/tree/65afe561 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/diff/65afe561 Branch: refs/heads/spec Commit: 65afe56149bfcaab2e3d009a55ee591c49317290 Parents: 9245431 Author: vintagewang <[email protected]> Authored: Sun Dec 25 20:10:20 2016 +0800 Committer: vintagewang <[email protected]> Committed: Sun Dec 25 20:10:20 2016 +0800 ---------------------------------------------------------------------- .../java/src/main/java/org/apache/openmessaging/Message.java | 1 - .../main/java/org/apache/openmessaging/MessagingEndPoint.java | 1 - .../java/org/apache/openmessaging/MessagingEndPointManager.java | 1 - .../java/src/main/java/org/apache/openmessaging/Producer.java | 1 - .../src/main/java/org/apache/openmessaging/PullConsumer.java | 1 - .../src/main/java/org/apache/openmessaging/PushConsumer.java | 1 - .../apache/openmessaging/internal/MessagingEndPointAdapter.java | 1 - .../apache/openmessaging/internal/MessagingEndPointFactory.java | 1 - .../java/org/apache/openmessaging/internal/ServiceConstants.java | 1 - .../java/org/apache/openmessaging/internal/URISpecParser.java | 1 - .../apache/openmessaging/wireapi/broker/BrokerAdminWireAPI.java | 1 - .../openmessaging/wireapi/broker/BrokerConsumeWireAPI.java | 1 - .../openmessaging/wireapi/broker/BrokerProduceWireAPI.java | 1 - .../org/apache/openmessaging/wireapi/broker/ConnectRequest.java | 1 - .../java/org/apache/openmessaging/wireapi/broker/Message.java | 1 - .../apache/openmessaging/wireapi/broker/SendBatchRequest.java | 1 - .../apache/openmessaging/wireapi/broker/SendBatchResponse.java | 1 - .../org/apache/openmessaging/wireapi/broker/SendOneRequest.java | 1 - .../org/apache/openmessaging/wireapi/broker/SendOneResponse.java | 1 - .../apache/openmessaging/wireapi/broker/SendOrderRequest.java | 1 - .../apache/openmessaging/wireapi/broker/SendOrderResponse.java | 1 - .../java/org/apache/openmessaging/wireapi/broker/Session.java | 1 - .../org/apache/openmessaging/wireapi/broker/Subscription.java | 1 - .../openmessaging/wireapi/client/ClientCallbackWireAPI.java | 1 - .../openmessaging/wireapi/consumer/ConsumerCallbackWireAPI.java | 3 +++ .../openmessaging/wireapi/consumer/ConsumerSelfWireAPI.java | 3 +++ .../apache/openmessaging/wireapi/naming/MetaServiceWireAPI.java | 4 +++- .../openmessaging/wireapi/naming/NameClientReadWireAPI.java | 3 +++ .../openmessaging/wireapi/naming/NameClientWriteWireAPI.java | 3 +++ .../openmessaging/wireapi/producer/ProducerCallbackWireAPI.java | 3 +++ 30 files changed, 18 insertions(+), 25 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 e4061f1..83a0a52 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 @@ -19,7 +19,6 @@ package org.apache.openmessaging; /** * @author [email protected] - * @since 2016-12-25 */ public interface Message { void start(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 1299857..f06d7e5 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 @@ -19,7 +19,6 @@ package org.apache.openmessaging; /** * @author [email protected] - * @since 2016-12-25 */ public interface MessagingEndPoint { void start(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 8909b71..5635893 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 @@ -26,7 +26,6 @@ import java.util.Properties; /** * @author [email protected] - * @since 2016-12-25 */ public class MessagingEndPointManager { public static MessagingEndPoint getMessagingEndPoint(String url) throws Exception { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 63c2abd..91ed147 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 @@ -18,7 +18,6 @@ package org.apache.openmessaging; /** * @author [email protected] - * @since 2016-12-25 */ public interface Producer { void start(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 fe2d819..66222ec 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 @@ -18,7 +18,6 @@ package org.apache.openmessaging; /** * @author [email protected] - * @since 2016-12-25 */ public interface PullConsumer { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 e233b1a..f12c291 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 @@ -18,7 +18,6 @@ package org.apache.openmessaging; /** * @author [email protected] - * @since 2016-12-25 */ public interface PushConsumer { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 8220f5c..9b2835d 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 @@ -28,7 +28,6 @@ import java.util.Properties; /** * @author [email protected] - * @since 2016-12-25 */ class MessagingEndPointAdapter { private static Map<String, String> serviceEndPointClassMap = new HashMap<String, String>(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 f2f8eda..7d521ff 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 @@ -26,7 +26,6 @@ import java.util.Properties; /** * @author [email protected] - * @since 2016-12-25 */ public class MessagingEndPointFactory { public static MessagingEndPoint createMessagingEndPoint(Map<String, List<String>> url, Properties properties) http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 13cd376..f445a9c 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 @@ -19,7 +19,6 @@ package org.apache.openmessaging.internal; /** * @author [email protected] - * @since 2016-12-25 */ class ServiceConstants { public static final String PROTOCOL_NAME = "protocol"; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 1d7a8e1..0b6feac 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 @@ -25,7 +25,6 @@ import java.util.Map; /** * @author [email protected] - * @since 2016-12-25 */ public class URISpecParser { public static Map<String, List<String>> parseURI(String uri) { http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 7af470f..33841b8 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 @@ -19,7 +19,6 @@ package org.apache.openmessaging.wireapi.broker; /** * @author [email protected] - * @since 2016-12-25 */ public interface BrokerAdminWireAPI { } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 0473ea7..10a19fe 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 @@ -19,7 +19,6 @@ package org.apache.openmessaging.wireapi.broker; /** * @author [email protected] - * @since 2016-12-25 */ public interface BrokerConsumeWireAPI { Session connect(ConnectRequest request); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 d0259e0..4523c35 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 @@ -19,7 +19,6 @@ package org.apache.openmessaging.wireapi.broker; /** * @author [email protected] - * @since 2016-12-25 */ public interface BrokerProduceWireAPI { Session connect(ConnectRequest request); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 c3ac40b..d6bd042 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 @@ -19,7 +19,6 @@ package org.apache.openmessaging.wireapi.broker; /** * @author [email protected] - * @since 2016-12-25 */ public class ConnectRequest { private String localHostIP; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 008d4ba..b7037b9 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 @@ -22,7 +22,6 @@ import java.util.Map; /** * @author [email protected] - * @since 2016-12-25 */ public class Message { private Map<String, String> systemHeader; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 4e0db2e..10f722f 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 @@ -19,7 +19,6 @@ package org.apache.openmessaging.wireapi.broker; /** * @author [email protected] - * @since 2016-12-25 */ public class SendBatchRequest { private Message message; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 ef83cbb..bbeba60 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 @@ -19,7 +19,6 @@ package org.apache.openmessaging.wireapi.broker; /** * @author [email protected] - * @since 2016-12-25 */ public class SendBatchResponse { } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 c9f7073..f1c868d 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 @@ -19,7 +19,6 @@ package org.apache.openmessaging.wireapi.broker; /** * @author [email protected] - * @since 2016-12-25 */ public class SendOneRequest { private Session session; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 e421337..1eeef75 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 @@ -19,7 +19,6 @@ package org.apache.openmessaging.wireapi.broker; /** * @author [email protected] - * @since 2016-12-25 */ public class SendOneResponse { } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 3ad6ec8..13ce72c 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 @@ -19,7 +19,6 @@ package org.apache.openmessaging.wireapi.broker; /** * @author [email protected] - * @since 2016-12-25 */ public class SendOrderRequest { private Message message; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 9c52e69..507b1bb 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 @@ -19,7 +19,6 @@ package org.apache.openmessaging.wireapi.broker; /** * @author [email protected] - * @since 2016-12-25 */ public class SendOrderResponse { } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 0c0a7b7..8da95d8 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 @@ -19,7 +19,6 @@ package org.apache.openmessaging.wireapi.broker; /** * @author [email protected] - * @since 2016-12-25 */ public class Session { private String sessionID; http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 b3d2314..7bcac53 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 @@ -19,7 +19,6 @@ package org.apache.openmessaging.wireapi.broker; /** * @author [email protected] - * @since 2016-12-25 */ public class Subscription { } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 0247fba..dd1a555 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 @@ -19,7 +19,6 @@ package org.apache.openmessaging.wireapi.client; /** * @author [email protected] - * @since 2016-12-25 */ public interface ClientCallbackWireAPI { void ping(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 ba281ef..a7dbabb 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 @@ -19,6 +19,9 @@ package org.apache.openmessaging.wireapi.consumer; import org.apache.openmessaging.wireapi.client.ClientCallbackWireAPI; +/** + * @author [email protected] + */ public interface ConsumerCallbackWireAPI extends ClientCallbackWireAPI { void push(); } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 52409cd..60cb480 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 @@ -17,6 +17,9 @@ package org.apache.openmessaging.wireapi.consumer; +/** + * @author [email protected] + */ public interface ConsumerSelfWireAPI { void forward(); } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 a81e965..791689c 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 @@ -17,7 +17,9 @@ package org.apache.openmessaging.wireapi.naming; - +/** + * @author [email protected] + */ public interface MetaServiceWireAPI { void createTopic(); http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 b2cca66..afe5bf6 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 @@ -17,5 +17,8 @@ package org.apache.openmessaging.wireapi.naming; +/** + * @author [email protected] + */ public interface NameClientReadWireAPI { } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 2cd845e..c416c66 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 @@ -17,5 +17,8 @@ package org.apache.openmessaging.wireapi.naming; +/** + * @author [email protected] + */ public interface NameClientWriteWireAPI { } http://git-wip-us.apache.org/repos/asf/incubator-rocketmq/blob/65afe561/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 ff9fd27..8228d66 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 @@ -19,6 +19,9 @@ package org.apache.openmessaging.wireapi.producer; import org.apache.openmessaging.wireapi.client.ClientCallbackWireAPI; +/** + * @author [email protected] + */ public interface ProducerCallbackWireAPI extends ClientCallbackWireAPI { void checkTransactionState(); }
