You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2022/07/04 05:42:25 UTC
[rocketmq-clients] branch cpp updated (828fd30 -> e71afb2)
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a change to branch cpp
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
discard 828fd30 Fix typo
discard 2ba08b9 Fix to make it compile on Windows
discard d8493e3 Add sha256 for grpc
discard 4a6a515 Upgrade bazel version
discard 5f76828 Fix clang check
discard 75ea90f Use matrix
discard 4735ead Try to build on Linux, MacOS, Windows
discard 6b31ad5 Use official gRPC release v1.46.3
discard 056e68c Upgrade grpc to v1.46.3.2
discard c5bbe34 Upgrade grpc to v1.46.3.1
discard 747d699 Fix url of bazel_proto mirror
discard cde80b0 Add mirror for rules_proto
discard a5aa904 Add io_bazel_rules_go mirror
discard 390a87e Add dependent CDN through OSS
discard fcf63ce Translate ClientIdRequired to InternalClientError
discard bae23b8 Add error handling
discard 9c859cb Add error handling for NotifyClientTermination
discard f40067b Add error handling for EndTransaction
discard ce9a35f Add error handling for Ack
discard b4a2e50 Add error handling for ReceiveMessage
discard 1b1dfd0 Complete error handling for QueryAssignment
discard efdd9e1 Finish error handling of SendMessage
discard 4a9426e Complete error handling for Heartbeat
discard acee141 Complete error handling of QueryRoute
discard 00080c3 Sync and update protobuf files to v2.0-alpha
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
add 15709fe Docs: polish the java part (#23)
add 339044b Docs: fix typo
add 240c2f9 Sync and update protobuf files to v2.0-alpha
add dd1cb80 Complete error handling of QueryRoute
add 97c1c85 Complete error handling for Heartbeat
add 41919fa Finish error handling of SendMessage
add cfb8b66 Complete error handling for QueryAssignment
add 4454106 Add error handling for ReceiveMessage
add 0f834fc Add error handling for Ack
add 1ba0fbe Add error handling for EndTransaction
add 2cb2b23 Add error handling for NotifyClientTermination
add 402189e Add error handling
add d01da9c Translate ClientIdRequired to InternalClientError
add 240d59c Add dependent CDN through OSS
add 6196639 Add io_bazel_rules_go mirror
add be6acda Add mirror for rules_proto
add b1e981b Fix url of bazel_proto mirror
add a7021d9 Upgrade grpc to v1.46.3.1
add 006f2e8 Upgrade grpc to v1.46.3.2
add 39c65e3 Use official gRPC release v1.46.3
add d605a62 Try to build on Linux, MacOS, Windows
add 5b0f9d3 Use matrix
add 24a50ed Fix clang check
add ca70364 Upgrade bazel version
add 25bd3b1 Add sha256 for grpc
add e76dc7d Fix to make it compile on Windows
add e71afb2 Fix typo
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (828fd30)
\
N -- N -- N refs/heads/cpp (e71afb2)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/java_build.yml | 14 ++-
java/README.md | 85 ++------------
.../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/{README.md => example.md} | 50 ++------
java/style/spotbugs-suppressions.xml | 41 ++++++-
35 files changed, 539 insertions(+), 628 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%)
copy java/{README.md => example.md} (58%)