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 <[email protected]> Authored: Wed Dec 28 14:14:59 2016 +0800 Committer: vintagewang <[email protected]> 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 [email protected] - */ + 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 [email protected] - */ 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + 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 [email protected] - */ + public interface ProducerCallbackWireAPI extends ClientCallbackWireAPI { void checkTransactionState(); }
