This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a change to branch OpenMessaging
in repository https://gitbox.apache.org/repos/asf/rocketmq-ons.git.
from 0d9f225 Merge pull request #14 from duhenglucky/OpenMessaging
new d7493f0 feat(trace)adapted to support RocketMQ native client
new e46fac7 feat(client) use the trace rpc hook in trace core replace
origin rpc hook
new 51e20e3 feat(ons-client) remove the dependency of ons-auth4client
new 98c6cfb Merge pull request #17 from duhenglucky/auth
The 43 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
ons-core/ons-client/pom.xml | 21 ++++--
.../org/apache/rocketmq/ons/api/Constants.java | 2 +
.../exception/AuthenticationException.java | 1 -
.../rocketmq/ons/api/impl/rocketmq/ONSChannel.java | 4 ++
.../ons/api/impl/rocketmq/ONSClientAbstract.java | 33 ++--------
.../ons/api/impl/rocketmq/ONSConsumerAbstract.java | 13 ++--
.../ons/api/impl/rocketmq/OnsClientRPCHook.java | 28 ++++++--
.../ons/api/impl/rocketmq/OrderProducerImpl.java | 14 ++--
.../ons/api/impl/rocketmq/ProducerImpl.java | 9 ++-
.../ons/api/impl/rocketmq/PullConsumerImpl.java | 3 +-
.../api/impl/rocketmq/TransactionProducerImpl.java | 11 ++--
ons-core/ons-trace-core/pom.xml | 5 --
.../open/trace/core/common/OnsTraceConstants.java | 9 ++-
.../open/trace/core/dispatch/AsyncDispatcher.java | 2 +
.../core/dispatch/impl/AsyncArrayDispatcher.java | 76 +++++++++++++---------
.../core/dispatch/impl/TraceProducerFactory.java | 44 +++----------
.../ons/open/trace/core/hook/AbstractRPCHook.java | 72 --------------------
.../core/hook}/OnsClientSendMessageHookImpl.java | 2 +-
.../core/hook}/OnsConsumeMessageHookImpl.java | 2 +-
ons-core/pom.xml | 5 ++
20 files changed, 140 insertions(+), 216 deletions(-)
copy ons-core/{ons-auth4client =>
ons-client}/src/main/java/org/apache/rocketmq/ons/api/impl/authority/exception/AuthenticationException.java
(99%)
copy ons-core/{ons-auth4client =>
ons-client}/src/main/java/org/apache/rocketmq/ons/api/impl/rocketmq/ONSChannel.java
(99%)
delete mode 100644
ons-core/ons-trace-core/src/main/java/org/apache/rocketmq/ons/open/trace/core/hook/AbstractRPCHook.java
rename
ons-core/{ons-client/src/main/java/org/apache/rocketmq/ons/api/impl/tracehook
=>
ons-trace-core/src/main/java/org/apache/rocketmq/ons/open/trace/core/hook}/OnsClientSendMessageHookImpl.java
(98%)
rename
ons-core/{ons-client/src/main/java/org/apache/rocketmq/ons/api/impl/tracehook
=>
ons-trace-core/src/main/java/org/apache/rocketmq/ons/open/trace/core/hook}/OnsConsumeMessageHookImpl.java
(99%)
