You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by aa...@apache.org on 2022/07/18 10:46:53 UTC
[rocketmq-clients] branch java_dev updated (98d6727 -> 1548810)
This is an automated email from the ASF dual-hosted git repository.
aaronai pushed a change to branch java_dev
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
from 98d6727 Check maxMessageNum before receiving message
add 1548810 Polish code
No new revisions were added by this update.
Summary of changes:
.../rocketmq/client/java/impl/ClientImpl.java | 25 ++++----
.../rocketmq/client/java/impl/ClientManager.java | 22 +++----
.../client/java/impl/ClientManagerImpl.java | 22 +++----
.../client/java/impl/consumer/ConsumerImpl.java | 32 +++++-----
.../java/impl/consumer/ProcessQueueImpl.java | 45 +++++++-------
.../java/impl/consumer/PushConsumerImpl.java | 24 ++++----
.../java/impl/consumer/SimpleConsumerImpl.java | 24 ++++----
.../client/java/impl/producer/ProducerImpl.java | 20 +++----
.../client/java/impl/producer/SendReceiptImpl.java | 12 ++--
.../client/java/route/TopicRouteDataResult.java | 12 ++--
.../java/rpc/{RpcContext.java => Context.java} | 4 +-
.../apache/rocketmq/client/java/rpc/RpcClient.java | 20 +++----
.../rocketmq/client/java/rpc/RpcClientImpl.java | 26 ++++-----
.../{InvocationContext.java => RpcInvocation.java} | 16 ++---
.../java/impl/consumer/ProcessQueueImplTest.java | 10 ++--
.../java/impl/consumer/SimpleConsumerImplTest.java | 38 ++++++------
.../java/impl/producer/ProducerImplTest.java | 22 +++----
.../apache/rocketmq/client/java/tool/TestBase.java | 68 +++++++++++-----------
18 files changed, 222 insertions(+), 220 deletions(-)
rename java/client/src/main/java/org/apache/rocketmq/client/java/rpc/{RpcContext.java => Context.java} (93%)
rename java/client/src/main/java/org/apache/rocketmq/client/java/rpc/{InvocationContext.java => RpcInvocation.java} (78%)