This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git.
from ea09ce0 [issue #670]change the way to create newGroupChannelTable
(#1412)
new c6c699e [RIP-16]impl rpc support
new 46b2e12 [RIP-16]impl rpc support - code format
new 1d3a508 [RIP-16]fix test case error
new 7e221e5 add example of request-response model
new cc0a5e3 code format
new 53a6955 [RIP-16]change the way creating reply message
new ec1f926 optimize request/response examples
new 28936fa add reply interface to consumer
new 8c372b4 optimize ReplyMessageProcessor
new 5e1732a add unittest of request/response pattern
new 4c4bf10 add unittest of request/response pattern
new 58aa805 Merge branch 'rocketmq-unittest' of
https://github.com/qqeasonchen/rocketmq into rocketmq-dev-rpc
new c434ff4 Merge branch 'develop' of https://github.com/apache/rocketmq
into rocketmq-dev-rpc
new cc7543f add reply interface to DefaultLitePullConsumer
new 7772850 fix unit test err
new 0c47fcf add recommend client configs in rpc mode
new e7b9169 optimize unit test
new 8353551 add unit test of reply
new 18e44c2 remove reply interface in consumer
new a8c9fe6 add err code when create reply message exception
new ebc0ede optimization exception declare of request
new 9800afb rename REQUEST_UNIQ_ID to CORRELATION_ID
new f16fd08 rename REPLY_TO to REPLY_TO_CLIENT
new 4fa263f code style format
new b6e4be8 fix unit test
new 01827c8 remove unused code and fix typo
new 119feee use RemotingUtil to parse address
new a314e17 remove unused import
new c6cbab9 resolve Conflicts: #
broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
new e735fff Merge pull request #1422 from qqeasonchen/rocketmq-dev-rpc
The 1264 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:
.../apache/rocketmq/broker/BrokerController.java | 27 ++
.../rocketmq/broker/client/ProducerManager.java | 13 +-
.../broker/processor/ReplyMessageProcessor.java | 342 +++++++++++++++++++++
.../broker/processor/SendMessageProcessor.java | 6 +-
.../rocketmq/broker/topic/TopicConfigManager.java | 12 +-
.../broker/client/ProducerManagerTest.java | 18 +-
.../processor/ReplyMessageProcessorTest.java | 137 +++++++++
.../org/apache/rocketmq/client/ClientConfig.java | 16 +-
.../rocketmq/client/common/ClientErrorCode.java | 2 +
...Exception.java => RequestTimeoutException.java} | 16 +-
.../client/impl/ClientRemotingProcessor.java | 83 ++++-
.../rocketmq/client/impl/MQClientAPIImpl.java | 34 +-
.../impl/consumer/DefaultLitePullConsumerImpl.java | 9 +-
.../impl/consumer/DefaultMQPushConsumerImpl.java | 17 +-
.../impl/producer/DefaultMQProducerImpl.java | 252 ++++++++++++++-
.../client/producer/DefaultMQProducer.java | 178 +++++++++--
.../rocketmq/client/producer/MQProducer.java | 23 ++
.../{SendCallback.java => RequestCallback.java} | 7 +-
.../client/producer/RequestFutureTable.java | 62 ++++
.../client/producer/RequestResponseFuture.java | 121 ++++++++
.../apache/rocketmq/client/utils/MessageUtil.java | 55 ++++
.../rocketmq/client/impl/MQClientAPIImplTest.java | 36 ++-
.../client/producer/DefaultMQProducerTest.java | 101 +++++-
.../client/producer/RequestResponseFutureTest.java | 27 +-
.../rocketmq/client/utils/MessageUtilsTest.java | 80 +++++
.../org/apache/rocketmq/common/BrokerConfig.java | 30 +-
.../java/org/apache/rocketmq/common/MixAll.java | 13 +-
.../rocketmq/common/message/MessageConst.java | 14 +
.../rocketmq/common/protocol/RequestCode.java | 6 +
...tHeader.java => ReplyMessageRequestHeader.java} | 44 +--
.../Operand.java => utils/CorrelationIdUtil.java} | 10 +-
.../rocketmq/example/rpc/AsyncRequestProducer.java | 63 ++++
.../Producer.java => rpc/RequestProducer.java} | 36 +--
.../ResponseConsumer.java} | 50 ++-
34 files changed, 1792 insertions(+), 148 deletions(-)
create mode 100644
broker/src/main/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessor.java
create mode 100644
broker/src/test/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessorTest.java
copy
client/src/main/java/org/apache/rocketmq/client/exception/{MQClientException.java
=> RequestTimeoutException.java} (75%)
copy
client/src/main/java/org/apache/rocketmq/client/producer/{SendCallback.java =>
RequestCallback.java} (87%)
create mode 100644
client/src/main/java/org/apache/rocketmq/client/producer/RequestFutureTable.java
create mode 100644
client/src/main/java/org/apache/rocketmq/client/producer/RequestResponseFuture.java
create mode 100644
client/src/main/java/org/apache/rocketmq/client/utils/MessageUtil.java
copy
common/src/test/java/org/apache/rocketmq/common/message/MessageClientIDSetterTest.java
=>
client/src/test/java/org/apache/rocketmq/client/producer/RequestResponseFutureTest.java
(53%)
create mode 100644
client/src/test/java/org/apache/rocketmq/client/utils/MessageUtilsTest.java
copy
common/src/main/java/org/apache/rocketmq/common/protocol/header/{SendMessageRequestHeader.java
=> ReplyMessageRequestHeader.java} (82%)
copy common/src/main/java/org/apache/rocketmq/common/{filter/impl/Operand.java
=> utils/CorrelationIdUtil.java} (80%)
create mode 100644
example/src/main/java/org/apache/rocketmq/example/rpc/AsyncRequestProducer.java
copy example/src/main/java/org/apache/rocketmq/example/{simple/Producer.java
=> rpc/RequestProducer.java} (60%)
copy
example/src/main/java/org/apache/rocketmq/example/{simple/PushConsumer.java =>
rpc/ResponseConsumer.java} (51%)
