This is an automated email from the ASF dual-hosted git repository.
aaronai pushed a change to branch java
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
from fd7eb2c Java: fix compile issue on JDK17
add 15709fe Docs: polish the java part (#23)
add 339044b Docs: fix typo
add bd3f083 Make the CPP codebase compiles on popular platforms
Mac/Windows/Linux (#24)
add 8042fef Java: bugfix about forgetting to start consumer service
during client startup
add 9b8e5b5 Java: fix opposite judgement for delay consumption (#25)
add 7572bee Golang: Initial commit (#19)
add 4232830 Java: adapt for the latest protocol (#27)
add 75279e1 Golang: add github action (#28)
add a471703 Polish docs
new ceceb12 Java: Add invocation context
The 1 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:
.asf.yaml | 9 +-
.github/workflows/cpp_build.yml | 11 +-
.github/workflows/csharp_build.yml | 4 +-
.github/workflows/golang_build.yml | 20 +
.github/workflows/java_build.yml | 2 +-
README.md | 1 +
cpp/.bazelrc | 4 +-
cpp/.bazelversion | 2 +-
cpp/api/rocketmq/ErrorCode.h | 107 +-
cpp/api/rocketmq/Tracing.h | 10 +-
cpp/bazel/rocketmq_deps.bzl | 55 +-
cpp/proto/apache/rocketmq/v2/definition.proto | 178 +-
cpp/proto/apache/rocketmq/v2/service.proto | 7 +
cpp/src/main/cpp/base/ErrorCategory.cpp | 29 +-
cpp/src/main/cpp/base/tests/RetryPolicyTest.cpp | 14 +-
cpp/src/main/cpp/client/ClientManagerImpl.cpp | 515 ++-
.../main/cpp/client/ReceiveMessageStreamReader.cpp | 54 +-
cpp/src/main/cpp/client/RpcClientImpl.cpp | 4 +-
cpp/src/main/cpp/client/TelemetryBidiReactor.cpp | 4 +-
cpp/src/main/cpp/client/include/ClientConfig.h | 7 +-
cpp/src/main/cpp/client/include/RpcClient.h | 7 +-
cpp/src/main/cpp/client/include/RpcClientImpl.h | 7 +-
cpp/src/main/cpp/rocketmq/ProcessQueueImpl.cpp | 4 +-
cpp/src/main/cpp/rocketmq/ProducerImpl.cpp | 13 +-
cpp/src/main/cpp/rocketmq/PushConsumerImpl.cpp | 2 +-
cpp/src/main/cpp/rocketmq/include/ClientImpl.h | 6 +
cpp/src/main/cpp/stats/PublishStats.cpp | 2 +-
docs/artwork/unified_apis_and_spec.png | Bin 119393 -> 627146
bytes
golang/README.md | 31 +
golang/broker.go | 364 +++
golang/broker_options.go | 112 +
.../cpp/base/ErrorCode.cpp => golang/config.go | 16 +-
golang/conn.go | 201 ++
golang/conn_options.go | 189 ++
golang/consumer.go | 153 +
.../BrokerData.cpp => golang/consumer_options.go | 62 +-
.../credentials/credentials.go | 13 +-
golang/example/consumer/main.go | 60 +
golang/example/producer/main.go | 69 +
golang/go.mod | 28 +
golang/go.sum | 207 ++
.../main/cpp/base/Tracing.cpp => golang/message.go | 22 +-
.../AdminServer.h => golang/metadata/metadata.go | 49 +-
golang/ns.go | 179 ++
golang/ns_options.go | 105 +
golang/pkg/grpc/middleware/zaplog/zaplog.go | 56 +
.../TransactionImpl.cpp => golang/pkg/net/net.go | 56 +-
.../LinkedElement.java => golang/pkg/os/host.go | 18 +-
.../State.h => golang/pkg/ticker/ticker.go | 34 +-
golang/pkg/zaplog/ctxzap/ctxzap.go | 64 +
golang/pkg/zaplog/logger.go | 58 +
golang/pkg/zaplog/options.go | 88 +
.../MetadataConstants.h => golang/producer.go | 73 +-
golang/producer_options.go | 55 +
golang/protocol/v1/admin.pb.go | 246 ++
golang/protocol/v1/definition.pb.go | 1407 ++++++++
golang/protocol/v1/service.pb.go | 3342 ++++++++++++++++++++
java/README.md | 85 +-
.../rocketmq/client/apis/ClientException.java | 24 +-
.../rocketmq/client/java/impl/ClientImpl.java | 22 +-
.../rocketmq/client/java/impl/ClientManager.java | 48 +-
.../client/java/impl/ClientManagerImpl.java | 71 +-
.../client/java/impl/consumer/ConsumeService.java | 9 +-
.../client/java/impl/consumer/ConsumerImpl.java | 41 +-
.../java/impl/consumer/FifoConsumeService.java | 14 +
.../java/impl/consumer/ProcessQueueImpl.java | 46 +-
.../java/impl/consumer/PushConsumerImpl.java | 31 +-
.../java/impl/consumer/PushConsumerSettings.java | 4 +-
.../java/impl/consumer/ReceiveMessageResult.java | 8 +-
.../java/impl/consumer/SimpleConsumerImpl.java | 19 +-
.../java/impl/consumer/SimpleConsumerSettings.java | 4 +-
.../java/impl/consumer/StandardConsumeService.java | 14 +
.../client/java/impl/producer/ProducerImpl.java | 21 +-
.../rocketmq/client/java/message/MessageImpl.java | 2 +-
.../client/java/message/MessageViewImpl.java | 16 +-
.../client/java/message/PublishingMessageImpl.java | 5 +
.../rocketmq/client/java/metrics/MessageMeter.java | 13 +-
.../rocketmq/client/java/misc/LinkedElement.java | 11 +
.../rocketmq/client/java/misc/LinkedIterator.java | 11 +
.../InvocationContext.java} | 36 +-
.../apache/rocketmq/client/java/rpc/RpcClient.java | 51 +-
.../rocketmq/client/java/rpc/RpcClientImpl.java | 100 +-
.../java/{impl/Client.java => rpc/RpcContext.java} | 35 +-
.../apache/rocketmq/client/java/rpc/Signature.java | 2 +-
.../apache/rocketmq/client/java/rpc/TLSHelper.java | 7 +-
.../java/impl/consumer/ProcessQueueImplTest.java | 15 +-
.../java/impl/consumer/PushConsumerImplTest.java | 6 +-
.../java/impl/consumer/SimpleConsumerImplTest.java | 13 +-
.../java/impl/producer/ProducerImplTest.java | 21 +-
.../apache/rocketmq/client/java/tool/TestBase.java | 97 +-
java/{README.md => example.md} | 50 +-
91 files changed, 8520 insertions(+), 867 deletions(-)
create mode 100644 .github/workflows/golang_build.yml
create mode 100644 golang/README.md
create mode 100644 golang/broker.go
create mode 100644 golang/broker_options.go
copy cpp/src/main/cpp/base/ErrorCode.cpp => golang/config.go (65%)
create mode 100644 golang/conn.go
create mode 100644 golang/conn_options.go
create mode 100644 golang/consumer.go
copy cpp/src/main/cpp/remoting/BrokerData.cpp => golang/consumer_options.go
(52%)
copy cpp/src/main/cpp/base/ErrorCode.cpp => golang/credentials/credentials.go
(74%)
create mode 100644 golang/example/consumer/main.go
create mode 100644 golang/example/producer/main.go
create mode 100644 golang/go.mod
create mode 100644 golang/go.sum
rename cpp/src/main/cpp/base/Tracing.cpp => golang/message.go (74%)
copy cpp/api/rocketmq/AdminServer.h => golang/metadata/metadata.go (61%)
create mode 100644 golang/ns.go
create mode 100644 golang/ns_options.go
create mode 100644 golang/pkg/grpc/middleware/zaplog/zaplog.go
copy cpp/src/main/cpp/rocketmq/TransactionImpl.cpp => golang/pkg/net/net.go
(53%)
copy
java/client/src/main/java/org/apache/rocketmq/client/java/misc/LinkedElement.java
=> golang/pkg/os/host.go (83%)
copy cpp/api/rocketmq/State.h => golang/pkg/ticker/ticker.go (70%)
create mode 100644 golang/pkg/zaplog/ctxzap/ctxzap.go
create mode 100644 golang/pkg/zaplog/logger.go
create mode 100644 golang/pkg/zaplog/options.go
copy cpp/src/main/cpp/base/include/MetadataConstants.h => golang/producer.go
(52%)
create mode 100644 golang/producer_options.go
create mode 100644 golang/protocol/v1/admin.pb.go
create mode 100644 golang/protocol/v1/definition.pb.go
create mode 100644 golang/protocol/v1/service.pb.go
copy
java/client/src/main/java/org/apache/rocketmq/client/java/{misc/LinkedIterator.java
=> rpc/InvocationContext.java} (59%)
copy
java/client/src/main/java/org/apache/rocketmq/client/java/{impl/Client.java =>
rpc/RpcContext.java} (62%)
copy java/{README.md => example.md} (58%)
