[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" failed!
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has failed. Run started by GitHub user 3424672656 (triggered by github-actions[bot]). Head commit for run: 593307f7dc0e956614ae5949451e7840c3202df8 / wanghuaiyuan fix test Report URL: https://github.com/apache/rocketmq/actions/runs/12908139837 With regards, GitHub Actions via GitBox
Re: [PR] [ISSUE #928] Fix C++ simple consumer error code and close function [rocketmq-clients]
lizhimins merged PR #931: URL: https://github.com/apache/rocketmq-clients/pull/931 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(rocketmq-clients) branch master updated: [ISSUE #928] Fix C++ simple consumer error code and close function (#931)
This is an automated email from the ASF dual-hosted git repository.
lizhimin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
The following commit(s) were added to refs/heads/master by this push:
new 55e7dd23 [ISSUE #928] Fix C++ simple consumer error code and close
function (#931)
55e7dd23 is described below
commit 55e7dd238489a521cd86cde6df557a35badcb807
Author: lizhimins <707364...@qq.com>
AuthorDate: Wed Jan 22 20:42:40 2025 +0800
[ISSUE #928] Fix C++ simple consumer error code and close function (#931)
---
cpp/examples/ExampleSimpleConsumer.cpp| 54 ---
cpp/proto/apache/rocketmq/v2/definition.proto | 128 +++-
cpp/proto/apache/rocketmq/v2/service.proto| 213 --
cpp/source/client/ClientManagerImpl.cpp | 2 +-
cpp/source/client/TelemetryBidiReactor.cpp| 16 +-
cpp/source/rocketmq/ClientImpl.cpp| 6 +-
cpp/source/rocketmq/SimpleConsumer.cpp| 3 +-
cpp/source/rocketmq/SimpleConsumerImpl.cpp| 28 +++-
8 files changed, 287 insertions(+), 163 deletions(-)
diff --git a/cpp/examples/ExampleSimpleConsumer.cpp
b/cpp/examples/ExampleSimpleConsumer.cpp
index 41262ad0..c28d2e4d 100644
--- a/cpp/examples/ExampleSimpleConsumer.cpp
+++ b/cpp/examples/ExampleSimpleConsumer.cpp
@@ -18,6 +18,7 @@
#include
#include "gflags/gflags.h"
+#include "rocketmq/ErrorCode.h"
#include "rocketmq/Logger.h"
#include "rocketmq/SimpleConsumer.h"
@@ -42,10 +43,11 @@ int main(int argc, char* argv[]) {
CredentialsProviderPtr credentials_provider;
if (!FLAGS_access_key.empty() && !FLAGS_access_secret.empty()) {
-credentials_provider =
std::make_shared(FLAGS_access_key,
FLAGS_access_secret);
+credentials_provider = std::make_shared(
+FLAGS_access_key, FLAGS_access_secret);
}
- // In most case, you don't need to create too many consumers, singletion
pattern is recommended.
+ // In most case, you don't need to create too many consumers, singleton
pattern is recommended.
auto simple_consumer = SimpleConsumer::newBuilder()
.withGroup(FLAGS_group)
.withConfiguration(Configuration::newBuilder()
@@ -54,32 +56,36 @@ int main(int argc, char* argv[]) {
.withSsl(FLAGS_tls)
.build())
.subscribe(FLAGS_topic, tag)
+ .withAwaitDuration(std::chrono::seconds(10))
.build();
- std::vector messages;
- std::error_code ec;
- simple_consumer.receive(4, std::chrono::seconds(3), ec, messages);
- if (ec) {
-std::cerr << "Failed to receive messages. Cause: " << ec.message() <<
std::endl;
-return EXIT_FAILURE;
- }
+ for (int j = 0; j < 30; j++) {
+std::vector messages;
+std::error_code ec;
+simple_consumer.receive(4, std::chrono::seconds(15), ec, messages);
+if (ec) {
+ std::cerr << "Failed to receive messages. Cause: " << ec.message() <<
std::endl;
+}
- std::cout << "Received " << messages.size() << " messages" << std::endl;
- std::size_t i = 0;
- for (const auto& message : messages) {
-std::cout << "Received a message[topic=" << message->topic() << ",
message-id=" << message->id()
- << ", receipt-handle='" << message->extension().receipt_handle
<< "']" << std::endl;
+std::cout << "Received " << messages.size() << " messages" << std::endl;
+std::size_t i = 0;
-std::error_code ec;
-if (++i % 2 == 0) {
- simple_consumer.ack(*message, ec);
- if (ec) {
-std::cerr << "Failed to ack message. Cause: " << ec.message() <<
std::endl;
- }
-} else {
- simple_consumer.changeInvisibleDuration(*message,
std::chrono::milliseconds(100), ec);
- if (ec) {
-std::cerr << "Failed to change invisible duration of message. Cause: "
<< ec.message() << std::endl;
+for (const auto& message : messages) {
+ std::cout << "Received a message[topic=" << message->topic()
+<< ", message-id=" << message->id()
+<< ", receipt-handle='" << message->extension().receipt_handle
+<< "']" << std::endl;
+
+ if (++i % 2 == 0) {
+simple_consumer.ack(*message, ec);
+if (ec) {
+ std::cerr << "Failed to ack message. Cause: " << ec.message() <<
std::endl;
+}
+ } else {
+simple_consumer.changeInvisibleDuration(*message,
std::chrono::seconds(3), ec);
+if (ec) {
+ std::cerr << "Failed to change invisible duration of message. Cause:
" << ec.message() << std::endl;
+}
}
}
}
diff --git a/cpp/proto/apache/rocketmq/v2/definition.proto
b/cpp/proto/apache/rocketmq/v2/definition.proto
index 67e58b8f..468c4105 100644
--- a/cpp/proto/apache/rocketmq/v2/definition.proto
+++ b/cpp/proto/apache/
[PR] [ISSUE #928] Fix C++ simple consumer and use a soft link to associate the proto files [rocketmq-clients]
lizhimins opened a new pull request, #931: URL: https://github.com/apache/rocketmq-clients/pull/931 … the proto files ### Which Issue(s) This PR Fixes Fixes #928 ### Brief Description ### How Did You Test This Change? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" failed!
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has failed. Run started by GitHub user 3424672656 (triggered by github-actions[bot]). Head commit for run: 593307f7dc0e956614ae5949451e7840c3202df8 / wanghuaiyuan fix test Report URL: https://github.com/apache/rocketmq/actions/runs/12908139837 With regards, GitHub Actions via GitBox
Re: [PR] fix violation of Sonarqube rule java:S2111 [rocketmq]
github-actions[bot] commented on PR #7722: URL: https://github.com/apache/rocketmq/pull/7722#issuecomment-2608538324 This PR was closed because it has been inactive for 3 days since being marked as stale. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] fix violation of Sonarqube rule java:S2111 [rocketmq]
github-actions[bot] closed pull request #7722: fix violation of Sonarqube rule java:S2111 URL: https://github.com/apache/rocketmq/pull/7722 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(rocketmq-clients) branch dependabot/maven/java/logback.version-1.5.14 deleted (was e0b2836a)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/maven/java/logback.version-1.5.14 in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git was e0b2836a chore(deps): bump logback.version from 1.2.9 to 1.5.14 in /java The revisions that were on this branch are still contained in other references; therefore, this change does not discard any commits from the repository.
Re: [PR] chore(deps): bump logback.version from 1.2.9 to 1.5.14 in /java [rocketmq-clients]
github-actions[bot] closed pull request #892: chore(deps): bump logback.version from 1.2.9 to 1.5.14 in /java URL: https://github.com/apache/rocketmq-clients/pull/892 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] [Feature] Python - There are some error to start a consumer in background thread [rocketmq-clients]
github-actions[bot] commented on issue #889: URL: https://github.com/apache/rocketmq-clients/issues/889#issuecomment-2608563191 This issue is stale because it has been open for 30 days with no activity. It will be closed in 3 days if no further activity occurs. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] chore(deps): bump logback.version from 1.2.9 to 1.5.14 in /java [rocketmq-clients]
dependabot[bot] commented on PR #892: URL: https://github.com/apache/rocketmq-clients/pull/892#issuecomment-2608563215 OK, I won't notify you again about this release, but will get in touch when a new version is available. If you change your mind, just re-open this PR and I'll resolve any conflicts on it. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] chore(deps): bump logback.version from 1.2.9 to 1.5.14 in /java [rocketmq-clients]
github-actions[bot] commented on PR #892: URL: https://github.com/apache/rocketmq-clients/pull/892#issuecomment-2608563168 This PR was closed because it has been inactive for 3 days since being marked as stale. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] [Bug] 并发异步发送消息时，报错 send request failed，导致消息无法发送 [rocketmq]
lvgitt commented on issue #8407: URL: https://github.com/apache/rocketmq/issues/8407#issuecomment-2608705820 为啥没人回复 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GH] (rocketmq-clients): Workflow run "Golang Coverage" failed!
The GitHub Actions job "Golang Coverage" on rocketmq-clients.git has failed. Run started by GitHub user lizhimins (triggered by lizhimins). Head commit for run: afd4f56d0d310852fbea836f6c1e8b5eec7bae2f / lizhimins <707364...@qq.com> [ISSUE #928] Fix C++ push consumer handle error code and change demo log level (#932) Report URL: https://github.com/apache/rocketmq-clients/actions/runs/12921826716 With regards, GitHub Actions via GitBox
Re: [PR] [ISSUE #928] Fix C++ push consumer handle error code and change demo log level [rocketmq-clients]
lizhimins merged PR #932: URL: https://github.com/apache/rocketmq-clients/pull/932 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(rocketmq-clients) branch master updated: [ISSUE #928] Fix C++ push consumer handle error code and change demo log level (#932)
This is an automated email from the ASF dual-hosted git repository.
lizhimin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
The following commit(s) were added to refs/heads/master by this push:
new afd4f56d [ISSUE #928] Fix C++ push consumer handle error code and
change demo log level (#932)
afd4f56d is described below
commit afd4f56d0d310852fbea836f6c1e8b5eec7bae2f
Author: lizhimins <707364...@qq.com>
AuthorDate: Thu Jan 23 11:41:11 2025 +0800
[ISSUE #928] Fix C++ push consumer handle error code and change demo log
level (#932)
---
cpp/examples/ExampleFifoProducer.cpp| 6 +++---
cpp/source/rocketmq/AsyncReceiveMessageCallback.cpp | 5 +
cpp/source/rocketmq/SimpleConsumerImpl.cpp | 4 ++--
3 files changed, 10 insertions(+), 5 deletions(-)
diff --git a/cpp/examples/ExampleFifoProducer.cpp
b/cpp/examples/ExampleFifoProducer.cpp
index 1e7829d4..1876ebb1 100644
--- a/cpp/examples/ExampleFifoProducer.cpp
+++ b/cpp/examples/ExampleFifoProducer.cpp
@@ -105,8 +105,8 @@ int main(int argc, char* argv[]) {
gflags::ParseCommandLineFlags(&argc, &argv, true);
auto& logger = getLogger();
- logger.setConsoleLevel(Level::Debug);
- logger.setLevel(Level::Debug);
+ logger.setConsoleLevel(Level::Info);
+ logger.setLevel(Level::Info);
logger.init();
// Access Key/Secret pair may be acquired from management console
@@ -172,7 +172,7 @@ int main(int argc, char* argv[]) {
semaphore->acquire();
producer.send(std::move(message), callback);
- std::cout << "Cached No." << i << " message" << std::endl;
+ // std::cout << "Cached No." << i << " message" << std::endl;
}
} catch (...) {
std::cerr << "Ah...No!!!" << std::endl;
diff --git a/cpp/source/rocketmq/AsyncReceiveMessageCallback.cpp
b/cpp/source/rocketmq/AsyncReceiveMessageCallback.cpp
index 1c96b095..f68c9f88 100644
--- a/cpp/source/rocketmq/AsyncReceiveMessageCallback.cpp
+++ b/cpp/source/rocketmq/AsyncReceiveMessageCallback.cpp
@@ -51,6 +51,11 @@ void AsyncReceiveMessageCallback::onCompletion(const
std::error_code& ec, const
return;
}
+ if (ec == ErrorCode::NoContent) {
+checkThrottleThenReceive();
+return;
+ }
+
if (ec) {
SPDLOG_WARN("Receive message from {} failed. Cause: {}. Retry after 1
second.", process_queue->simpleName(), ec.message());
receiveMessageLater(std::chrono::seconds (1));
diff --git a/cpp/source/rocketmq/SimpleConsumerImpl.cpp
b/cpp/source/rocketmq/SimpleConsumerImpl.cpp
index df060793..e0a78eeb 100644
--- a/cpp/source/rocketmq/SimpleConsumerImpl.cpp
+++ b/cpp/source/rocketmq/SimpleConsumerImpl.cpp
@@ -95,11 +95,11 @@ void SimpleConsumerImpl::start() {
}
};
-// refer java sdk: set refresh interval to 30 seconds
+// refer java sdk: set refresh interval to 5 seconds
// org.apache.rocketmq.client.java.impl.ClientImpl#startUp
refresh_assignment_task_ = manager()->getScheduler()->schedule(
refresh_assignment_task, "RefreshAssignmentTask",
-std::chrono::minutes(5), std::chrono::seconds(5));
+std::chrono::seconds(5), std::chrono::seconds(5));
client_manager_->addClientObserver(shared_from_this());
}
[GH] (rocketmq-clients): Workflow run "Rust Coverage" failed!
The GitHub Actions job "Rust Coverage" on rocketmq-clients.git has failed. Run started by GitHub user lizhimins (triggered by lizhimins). Head commit for run: afd4f56d0d310852fbea836f6c1e8b5eec7bae2f / lizhimins <707364...@qq.com> [ISSUE #928] Fix C++ push consumer handle error code and change demo log level (#932) Report URL: https://github.com/apache/rocketmq-clients/actions/runs/12921826705 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "CPP Coverage" failed!
The GitHub Actions job "CPP Coverage" on rocketmq-clients.git has failed. Run started by GitHub user lizhimins (triggered by lizhimins). Head commit for run: afd4f56d0d310852fbea836f6c1e8b5eec7bae2f / lizhimins <707364...@qq.com> [ISSUE #928] Fix C++ push consumer handle error code and change demo log level (#932) Report URL: https://github.com/apache/rocketmq-clients/actions/runs/12921826728 With regards, GitHub Actions via GitBox
[I] [Bug] runbroker.cmd miss %JAVA_OPT% on windows [rocketmq]
frankcrc opened a new issue, #9154: URL: https://github.com/apache/rocketmq/issues/9154 ### Before Creating the Bug Report - [x] I found a bug, not just asking a question, which should be created in [GitHub Discussions](https://github.com/apache/rocketmq/discussions). - [x] I have searched the [GitHub Issues](https://github.com/apache/rocketmq/issues) and [GitHub Discussions](https://github.com/apache/rocketmq/discussions) of this repository and believe that this is not a duplicate. - [x] I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ. ### Runtime platform environment Windows 11 ### RocketMQ version rocketmq 5.2.0 release ### JDK Version Oracle JDK 1.8_u202 ### Describe the Bug Run a namesrv, and check cmd line in Task Manager or Process Explorer, then you will see JAVA_OPT, like -Xmx, is missing. This is JAVA_OPT config in runserver.cmd.  This is CMD line of the namesrv process.  ### Steps to Reproduce 1. Prepare a namesrv config file, let say `namesrv.conf`. I think it does not matter, but just to reproduce my env. ``` enableControllerInNamesrv = true controllerDLegerGroup = group1 controllerDLegerPeers = n0-127.0.0.1:9877 controllerDLegerSelfId = n0 ``` 2. Prepare a powershell script file, let say `start-namesrv-w-c.ps1`. ``` $env:JAVA_OPT='-Duser.home=D:\data\mq_data\rocketmq-all-5.2.0-bin-release\data\namesrv' $env:ROCKETMQ_HOME='D:\data\mq_data\rocketmq-all-5.2.0-bin-release' D:\data\mq_data\rocketmq-all-5.2.0-bin-release\bin\mqnamesrv.cmd -c D:\data\mq_data\rocketmq-all-5.2.0-bin-release\data\namesrv.conf ``` 3. Open a Powershell and execute the script file, `.\start-namesrv-w-c.ps1`. 4. Check process cmd line. ### What Did You Expect to See? the java process cmd line should contain -Xmx300m and all other jvm options. ### What Did You See Instead? only JAVA_OPT what I set in `start-namesrv-w-c.ps1` is kept. ### Additional Context I think it should be the problem of batch variable substitution. When I comment out the IF statement, JAVA_OPT comes back.  This is CMD line of the namesrv process.  If possible, I would be happy to create a PR. Related Issue, https://github.com/apache/rocketmq/issues/8579, Related PR, https://github.com/apache/rocketmq/pull/7507 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[PR] [ISSUE #928] Fix C++ push consumer handle error code and change demo log level [rocketmq-clients]
lizhimins opened a new pull request, #932: URL: https://github.com/apache/rocketmq-clients/pull/932 ### Which Issue(s) This PR Fixes Fixes #928 ### Brief Description ### How Did You Test This Change? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GH] (rocketmq-clients): Workflow run "CPP Coverage" failed!
The GitHub Actions job "CPP Coverage" on rocketmq-clients.git has failed. Run started by GitHub user lizhimins (triggered by lizhimins). Head commit for run: 9b9089eabc0d53268a7b125364ecaea24ed96e3a / dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> chore(deps): bump ch.qos.logback:logback-core in /java (#904) Bumps [ch.qos.logback:logback-core](https://github.com/qos-ch/logback) from 1.2.9 to 1.3.15. - [Commits](https://github.com/qos-ch/logback/compare/v_1.2.9...v_1.3.15) --- updated-dependencies: - dependency-name: ch.qos.logback:logback-core dependency-type: direct:production ... Signed-off-by: dependabot[bot] Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Report URL: https://github.com/apache/rocketmq-clients/actions/runs/12923520664 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Rust Coverage" failed!
The GitHub Actions job "Rust Coverage" on rocketmq-clients.git has failed. Run started by GitHub user lizhimins (triggered by lizhimins). Head commit for run: 9b9089eabc0d53268a7b125364ecaea24ed96e3a / dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> chore(deps): bump ch.qos.logback:logback-core in /java (#904) Bumps [ch.qos.logback:logback-core](https://github.com/qos-ch/logback) from 1.2.9 to 1.3.15. - [Commits](https://github.com/qos-ch/logback/compare/v_1.2.9...v_1.3.15) --- updated-dependencies: - dependency-name: ch.qos.logback:logback-core dependency-type: direct:production ... Signed-off-by: dependabot[bot] Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Report URL: https://github.com/apache/rocketmq-clients/actions/runs/12923520679 With regards, GitHub Actions via GitBox
[I] [Doc] Documentation Related [rocketmq]
Lynxhide opened a new issue, #9155: URL: https://github.com/apache/rocketmq/issues/9155 ### Search before creation - [x] I had searched in the [issues](https://github.com/apache/rocketmq/issues) and found no similar issues. ### Documentation Related  文档这里IP地址有误 ### Are you willing to submit PR? - [x] Yes I am willing to submit a PR! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(rocketmq-clients) branch master updated: chore(deps): bump ch.qos.logback:logback-core in /java (#904)
This is an automated email from the ASF dual-hosted git repository. lizhimin pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git The following commit(s) were added to refs/heads/master by this push: new 9b9089ea chore(deps): bump ch.qos.logback:logback-core in /java (#904) 9b9089ea is described below commit 9b9089eabc0d53268a7b125364ecaea24ed96e3a Author: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> AuthorDate: Thu Jan 23 14:24:16 2025 +0800 chore(deps): bump ch.qos.logback:logback-core in /java (#904) Bumps [ch.qos.logback:logback-core](https://github.com/qos-ch/logback) from 1.2.9 to 1.3.15. - [Commits](https://github.com/qos-ch/logback/compare/v_1.2.9...v_1.3.15) --- updated-dependencies: - dependency-name: ch.qos.logback:logback-core dependency-type: direct:production ... Signed-off-by: dependabot[bot] Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> --- java/pom.xml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/java/pom.xml b/java/pom.xml index df27bfe0..0694f407 100644 --- a/java/pom.xml +++ b/java/pom.xml @@ -54,7 +54,7 @@ 1.50.0 32.0.0-jre 1.7.30 -1.2.9 +1.3.15 3.4 1.14.0 1.2.0
Re: [PR] chore(deps): bump ch.qos.logback:logback-core from 1.2.9 to 1.3.15 in /java [rocketmq-clients]
lizhimins merged PR #904: URL: https://github.com/apache/rocketmq-clients/pull/904 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
(rocketmq-clients) branch dependabot/maven/java/ch.qos.logback-logback-core-1.3.15 deleted (was d0a45b7b)
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/maven/java/ch.qos.logback-logback-core-1.3.15 in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git was d0a45b7b chore(deps): bump ch.qos.logback:logback-core in /java The revisions that were on this branch are still contained in other references; therefore, this change does not discard any commits from the repository.
[GH] (rocketmq-clients): Workflow run "Golang Coverage" failed!
The GitHub Actions job "Golang Coverage" on rocketmq-clients.git has failed. Run started by GitHub user lizhimins (triggered by lizhimins). Head commit for run: 9b9089eabc0d53268a7b125364ecaea24ed96e3a / dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> chore(deps): bump ch.qos.logback:logback-core in /java (#904) Bumps [ch.qos.logback:logback-core](https://github.com/qos-ch/logback) from 1.2.9 to 1.3.15. - [Commits](https://github.com/qos-ch/logback/compare/v_1.2.9...v_1.3.15) --- updated-dependencies: - dependency-name: ch.qos.logback:logback-core dependency-type: direct:production ... Signed-off-by: dependabot[bot] Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Report URL: https://github.com/apache/rocketmq-clients/actions/runs/12923520669 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "go_modules in /golang for google.golang.org/grpc - Update #952454833" failed!
The GitHub Actions job "go_modules in /golang for google.golang.org/grpc - Update #952454833" on rocketmq-clients.git has failed. Run started by GitHub user dependabot[bot] (triggered by dependabot[bot]). Head commit for run: 9b9089eabc0d53268a7b125364ecaea24ed96e3a / dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> chore(deps): bump ch.qos.logback:logback-core in /java (#904) Bumps [ch.qos.logback:logback-core](https://github.com/qos-ch/logback) from 1.2.9 to 1.3.15. - [Commits](https://github.com/qos-ch/logback/compare/v_1.2.9...v_1.3.15) --- updated-dependencies: - dependency-name: ch.qos.logback:logback-core dependency-type: direct:production ... Signed-off-by: dependabot[bot] Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Report URL: https://github.com/apache/rocketmq-clients/actions/runs/12923522027 With regards, GitHub Actions via GitBox
Re: [PR] [ISSUE #9141] [RIP-75] Supports timer message on RocksDB [rocketmq]
qianye1001 commented on code in PR #9142:
URL: https://github.com/apache/rocketmq/pull/9142#discussion_r1924915310
##
store/src/main/java/org/apache/rocketmq/store/timer/rocksdb/TimerMessageRocksDBStorage.java:
##
@@ -0,0 +1,269 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.rocketmq.store.timer.rocksdb;
+
+import org.apache.rocketmq.common.UtilAll;
+import org.apache.rocketmq.common.config.AbstractRocksDBStorage;
+import org.apache.rocketmq.common.constant.LoggerName;
+import org.apache.rocketmq.store.rocksdb.RocksDBOptionsFactory;
+import org.apache.rocketmq.logging.org.slf4j.Logger;
+import org.apache.rocketmq.logging.org.slf4j.LoggerFactory;
+import org.rocksdb.RocksDB;
+import org.rocksdb.WriteBatch;
+import org.rocksdb.ColumnFamilyDescriptor;
+import org.rocksdb.ColumnFamilyHandle;
+import org.rocksdb.WriteOptions;
+import org.rocksdb.ReadOptions;
+import org.rocksdb.CompactRangeOptions;
+import org.rocksdb.ColumnFamilyOptions;
+import org.rocksdb.RocksDBException;
+import org.rocksdb.Slice;
+import org.rocksdb.RocksIterator;
+
+import java.nio.ByteBuffer;
+import java.nio.charset.StandardCharsets;
+import java.util.ArrayList;
+import java.util.List;
+
+public class TimerMessageRocksDBStorage extends AbstractRocksDBStorage
implements TimerMessageKVStore {
+private final static Logger log =
LoggerFactory.getLogger(LoggerName.STORE_LOGGER_NAME);
+
+public final static byte[] TRANSACTION_COLUMN_FAMILY =
"transaction".getBytes(StandardCharsets.UTF_8);
+public final static byte[] POP_COLUMN_FAMILY =
"pop".getBytes(StandardCharsets.UTF_8);
+public final static byte[] TIMER_OFFSET_KEY =
"timer_offset".getBytes(StandardCharsets.UTF_8);
+
+// key : 100 * n (delay time); value : long (msg number)
+public final static byte[] METRIC_COLUMN_FAMILY =
"metric".getBytes(StandardCharsets.UTF_8);
+
+private ColumnFamilyHandle popColumnFamilyHandle;
+private ColumnFamilyHandle transactionColumnFamilyHandle;
+
+// Supports 100ms level statistics
+private ColumnFamilyHandle metricColumnFamilyHandle;
+
+private WriteOptions writeOptions;
+private WriteOptions deleteOptions;
+
+public TimerMessageRocksDBStorage(String filePath) {
+super(filePath);
+}
+
+@Override
+protected void initOptions() {
+this.options = RocksDBOptionsFactory.createDBOptions();
+
+this.deleteOptions = new WriteOptions();
+this.deleteOptions.setSync(false);
+this.deleteOptions.setDisableWAL(true);
+this.deleteOptions.setNoSlowdown(false);
+
+this.writeOptions = new WriteOptions();
+this.writeOptions.setSync(false);
+this.writeOptions.setDisableWAL(true);
+this.writeOptions.setNoSlowdown(false);
+
+this.compactRangeOptions = new CompactRangeOptions();
+this.compactRangeOptions.setBottommostLevelCompaction(
+CompactRangeOptions.BottommostLevelCompaction.kForce);
+this.compactRangeOptions.setAllowWriteStall(true);
+this.compactRangeOptions.setExclusiveManualCompaction(false);
+this.compactRangeOptions.setChangeLevel(true);
+this.compactRangeOptions.setTargetLevel(-1);
+this.compactRangeOptions.setMaxSubcompactions(4);
+}
+@Override
+protected boolean postLoad() {
+try {
+UtilAll.ensureDirOK(this.dbPath);
+initOptions();
+
+// init column family here
+ColumnFamilyOptions defaultOptions =
RocksDBOptionsFactory.createTimerCFOptions();
+ColumnFamilyOptions popOptions =
RocksDBOptionsFactory.createTimerCFOptions();
+ColumnFamilyOptions transactionOptions =
RocksDBOptionsFactory.createTimerCFOptions();
+ColumnFamilyOptions metricOptions =
RocksDBOptionsFactory.createTimerMetricCFOptions();
+
+this.cfOptions.add(defaultOptions);
+this.cfOptions.add(popOptions);
+this.cfOptions.add(transactionOptions);
+this.cfOptions.add(metricOptions);
+
+List cfDescriptors = new ArrayList<>();
+cfDescriptors.add(new
ColumnFamilyDescriptor(RocksDB.DEFAULT_COLUMN_FAMILY, defaultOption
