This is an automated email from the ASF dual-hosted git repository.
aaronai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
from 78a4791 Java: bugfix for MessageIdImpl#toString
add ff6dfff Java: implement error handling
add f979261 Java: remove message batch publishing
add 7a49d32 Java: use matrix to trigger CI
add fd7eb2c Java: fix compile issue on JDK17
No new revisions were added by this update.
Summary of changes:
.github/workflows/java_build.yml | 14 ++-
.../rocketmq/client/apis/ClientException.java | 4 +-
.../rocketmq/client/apis/producer/Producer.java | 13 ---
...oundException.java => BadRequestException.java} | 13 +--
...FoundException.java => ForbiddenException.java} | 13 +--
...dException.java => InternalErrorException.java} | 16 +--
...tFoundException.java => NotFoundException.java} | 13 ++-
...xception.java => PayloadTooLargeException.java} | 13 +--
...ndException.java => ProxyTimeoutException.java} | 14 +--
...a => RequestHeaderFieldsTooLargeException.java} | 16 +--
...xception.java => TooManyRequestsException.java} | 15 +--
...ndException.java => UnauthorizedException.java} | 14 +--
...undException.java => UnsupportedException.java} | 13 +--
.../rocketmq/client/java/impl/ClientImpl.java | 19 +--
.../client/java/impl/consumer/ConsumerImpl.java | 12 +-
.../java/impl/consumer/ProcessQueueImpl.java | 127 ++++++++++++---------
.../java/impl/consumer/PushConsumerImpl.java | 22 +---
.../java/impl/consumer/PushConsumerSettings.java | 3 +-
.../java/impl/consumer/ReceiveMessageResult.java | 76 ++++++++++--
.../java/impl/consumer/SimpleConsumerImpl.java | 114 +++++++++++-------
.../java/impl/consumer/SimpleConsumerSettings.java | 3 +-
...taResult.java => SubscriptionLoadBalancer.java} | 36 +++---
.../client/java/impl/producer/ProducerImpl.java | 44 ++++---
.../java/impl/producer/ProducerSettings.java | 3 +-
...DataResult.java => PublishingLoadBalancer.java} | 28 ++---
.../client/java/impl/producer/SendReceiptImpl.java | 80 +++++++++----
.../rocketmq/client/java/route/TopicRouteData.java | 6 +-
.../client/java/route/TopicRouteDataResult.java | 65 +++++++++--
.../impl/producer/ProducerBuilderImplTest.java | 21 ----
.../java/impl/producer/ProducerImplTest.java | 55 ---------
.../java/impl/producer/TransactionImplTest.java | 102 -----------------
.../apache/rocketmq/client/java/tool/TestBase.java | 4 +-
java/style/spotbugs-suppressions.xml | 41 ++++++-
33 files changed, 520 insertions(+), 512 deletions(-)
copy
java/client/src/main/java/org/apache/rocketmq/client/java/exception/{ResourceNotFoundException.java
=> BadRequestException.java} (77%)
copy
java/client/src/main/java/org/apache/rocketmq/client/java/exception/{ResourceNotFoundException.java
=> ForbiddenException.java} (77%)
copy
java/client/src/main/java/org/apache/rocketmq/client/java/exception/{ResourceNotFoundException.java
=> InternalErrorException.java} (74%)
copy
java/client/src/main/java/org/apache/rocketmq/client/java/exception/{ResourceNotFoundException.java
=> NotFoundException.java} (75%)
copy
java/client/src/main/java/org/apache/rocketmq/client/java/exception/{ResourceNotFoundException.java
=> PayloadTooLargeException.java} (76%)
copy
java/client/src/main/java/org/apache/rocketmq/client/java/exception/{ResourceNotFoundException.java
=> ProxyTimeoutException.java} (73%)
copy
java/client/src/main/java/org/apache/rocketmq/client/java/exception/{ResourceNotFoundException.java
=> RequestHeaderFieldsTooLargeException.java} (68%)
copy
java/client/src/main/java/org/apache/rocketmq/client/java/exception/{ResourceNotFoundException.java
=> TooManyRequestsException.java} (74%)
copy
java/client/src/main/java/org/apache/rocketmq/client/java/exception/{ResourceNotFoundException.java
=> UnauthorizedException.java} (75%)
rename
java/client/src/main/java/org/apache/rocketmq/client/java/exception/{ResourceNotFoundException.java
=> UnsupportedException.java} (80%)
rename
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/{SubscriptionTopicRouteDataResult.java
=> SubscriptionLoadBalancer.java} (70%)
rename
java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/{PublishingTopicRouteDataResult.java
=> PublishingLoadBalancer.java} (86%)
