This is an automated email from the ASF dual-hosted git repository. duhengforever pushed a commit to branch OpenMessaging in repository https://gitbox.apache.org/repos/asf/rocketmq-ons.git
commit 192acc024192bc5dda7798e0a5882e7d2c190931 Merge: 0523760 866bc7a Author: Heng Du <[email protected]> AuthorDate: Fri Nov 22 17:21:56 2019 +0800 Merge pull request #12 from duhenglucky/OpenMessaging [ISSUE #13]Add OpenMessaging API support ons-core/ons-api/pom.xml | 28 -- .../java/org/apache/rocketmq/ons/api/Action.java | 26 -- .../java/org/apache/rocketmq/ons/api/Admin.java | 37 --- .../apache/rocketmq/ons/api/ConsumeContext.java | 21 -- .../java/org/apache/rocketmq/ons/api/Consumer.java | 29 -- .../apache/rocketmq/ons/api/ExpressionType.java | 24 -- .../java/org/apache/rocketmq/ons/api/MQType.java | 38 --- .../java/org/apache/rocketmq/ons/api/Message.java | 251 ------------------ .../apache/rocketmq/ons/api/MessageAccessor.java | 41 --- .../apache/rocketmq/ons/api/MessageListener.java | 23 -- .../apache/rocketmq/ons/api/MessageSelector.java | 49 ---- .../org/apache/rocketmq/ons/api/ONSFactory.java | 88 ------- .../rocketmq/ons/api/OnExceptionContext.java | 56 ---- .../java/org/apache/rocketmq/ons/api/Producer.java | 37 --- .../org/apache/rocketmq/ons/api/SendCallback.java | 24 -- .../org/apache/rocketmq/ons/api/SendResult.java | 47 ---- .../rocketmq/ons/api/batch/BatchConsumer.java | 27 -- .../ons/api/batch/BatchMessageListener.java | 29 -- .../apache/rocketmq/ons/api/bean/Subscription.java | 93 ------- .../rocketmq/ons/api/bean/SubscriptionExt.java | 47 ---- .../ons/api/order/ConsumeOrderContext.java | 21 -- .../ons/api/order/MessageOrderListener.java | 25 -- .../ons/api/order/MessageQueueSelector.java | 25 -- .../apache/rocketmq/ons/api/order/OrderAction.java | 26 -- .../rocketmq/ons/api/order/OrderConsumer.java | 35 --- .../rocketmq/ons/api/order/OrderProducer.java | 28 -- .../api/transaction/LocalTransactionChecker.java | 24 -- .../api/transaction/LocalTransactionExecuter.java | 26 -- .../ons/api/transaction/TransactionProducer.java | 38 --- .../ons/api/transaction/TransactionStatus.java | 28 -- ons-core/ons-auth4client/pom.xml | 2 +- .../ons/api/impl/authority/SessionCredentials.java | 2 +- .../ons/api/impl/rocketmq/ClientRPCHook.java | 6 +- ons-core/ons-client/pom.xml | 11 +- .../rocketmq/MessagingAccessPointImpl.java} | 69 +++-- .../org/apache/rocketmq/ons/api/Constants.java | 1 + .../org/apache/rocketmq/ons/api/ONSFactory.java | 251 ++++++++++++++++++ .../org/apache/rocketmq/ons/api/ONSFactoryAPI.java | 24 +- .../apache/rocketmq/ons/api/PropertyKeyConst.java | 44 +--- .../rocketmq/ons/api/PropertyValueConst.java | 0 .../rocketmq/ons/api/bean/BatchConsumerBean.java | 32 ++- .../apache/rocketmq/ons/api/bean/ConsumerBean.java | 38 ++- .../rocketmq/ons/api/bean/OrderConsumerBean.java | 30 ++- .../rocketmq/ons/api/bean/OrderProducerBean.java | 29 +- .../apache/rocketmq/ons/api/bean/ProducerBean.java | 28 +- .../ons/api/bean/TransactionProducerBean.java | 38 ++- .../ons/api/exception/ONSClientException.java | 15 +- .../apache/rocketmq/ons/api/impl/MQClientInfo.java | 5 +- .../rocketmq/ons/api/impl/ONSFactoryImpl.java | 37 ++- .../ons/api/impl/rocketmq/BatchConsumerImpl.java | 13 +- .../ons/api/impl/rocketmq/ConsumerImpl.java | 15 +- .../ons/api/impl/rocketmq/ONSClientAbstract.java | 6 +- .../ons/api/impl/rocketmq/ONSConsumerAbstract.java | 15 +- .../rocketmq/ons/api/impl/rocketmq/ONSUtil.java | 13 +- .../ons/api/impl/rocketmq/OrderConsumerImpl.java | 14 +- .../ons/api/impl/rocketmq/OrderProducerImpl.java | 19 +- .../ons/api/impl/rocketmq/ProducerImpl.java | 33 ++- .../ons/api/impl/rocketmq/PullConsumerImpl.java | 291 +++++++++++++++++++++ .../api/impl/rocketmq/TransactionProducerImpl.java | 13 +- .../tracehook/OnsClientSendMessageHookImpl.java | 11 +- .../services/io.openmessaging.api.ONSFactoryAPI | 1 + .../impl/rocketmq/NameServerAutoUpdateTest.java | 39 +-- .../impl/rocketmq/ONSClientTokenUpdateTest.java | 44 ++-- ons-core/ons-trace-core/pom.xml | 2 +- ons-core/pom.xml | 14 +- ons-sample/pom.xml | 12 +- .../org/apache/rocketmq/ons/sample/MQConfig.java | 4 +- .../ons/sample/consumer/MessageListenerImpl.java | 8 +- .../ons/sample/consumer/SimpleMQConsumer.java | 21 +- .../ons/sample/consumer/SimpleOrderConsumer.java | 29 +- ...mpleMQConsumer.java => SimplePullConsumer.java} | 44 +++- .../producer/LocalTransactionCheckerImpl.java | 8 +- .../ons/sample/producer/MQTimerProducer.java | 30 ++- .../ons/sample/producer/SimpleMQProducer.java | 34 ++- .../ons/sample/producer/SimpleOrderProducer.java | 31 ++- .../sample/producer/SimpleTransactionProducer.java | 33 ++- pom.xml | 7 +- 77 files changed, 1122 insertions(+), 1635 deletions(-)
