Re: [I] [Doc] Documentation Related 有对nameserver进行权限访问吗。 [rocketmq]
dingshuangxi888 commented on issue #7542: URL: https://github.com/apache/rocketmq/issues/7542#issuecomment-1803375695 后面ACL这块会有一个比较完善的设计，敬请期待 -- 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
[PR] Replace lazy_static with once_cell [rocketmq-clients]
ixmoyren opened a new pull request, #636: URL: https://github.com/apache/rocketmq-clients/pull/636 lazy_static is almost inactive, most of the projects in the rust community use once_cell instead of lazy_static, while once_cell's performance is [a little bit more](https://github.com/matklad/once_cell/tree/master/examples) and the development is active. 1. remove lazy_static dependency 2. upgrade once_cell -- 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 "Rust Coverage" failed!
The GitHub Actions job "Rust Coverage" on rocketmq-clients.git has failed. Run started by GitHub user ixmoyren (triggered by lizhanhui). Head commit for run: 1e0b9f6f18882c873d10df160cc00b1983aeffbc / ixmoyren Replace lazy_static with once_cell Signed-off-by: iMXonren.Space Report URL: https://github.com/apache/rocketmq-clients/actions/runs/6809362855 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Build" failed!
The GitHub Actions job "Build" on rocketmq-clients.git has failed. Run started by GitHub user ixmoyren (triggered by lizhanhui). Head commit for run: 1e0b9f6f18882c873d10df160cc00b1983aeffbc / ixmoyren Replace lazy_static with once_cell Signed-off-by: iMXonren.Space Report URL: https://github.com/apache/rocketmq-clients/actions/runs/6809362873 With regards, GitHub Actions via GitBox
Re: [I] 是否稍微提高一下可扩展性和性能，都贡献给apache了能不能看起来像源码点？ [rocketmq-spring]
lizhanhui commented on issue #593: URL: https://github.com/apache/rocketmq-spring/issues/593#issuecomment-1803756678 首先感谢 @ChildrenGreens 指出项目的不足和可以改进的地方。 不过如你所述, 这是个开源项目并已经捐赠给Apache Software Foundation. 现在参与项目的同学来自很多公司和不同技术背景，项目Code-Review等流程也不够完善，因此可能产生不够好的设计、代码实现。 不过开源开放也有好的一面，任何人都可以提出建议，或者进一步，通过pull-request的方式，将项目演进的更好。 -- 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 "Rust Coverage" is working again!
The GitHub Actions job "Rust Coverage" on rocketmq-clients.git has succeeded. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: 133172b1955c20d5b2cac7549dc535a0a2454a24 / Li Zhanhui fix: sync transaction_producer example Signed-off-by: Li Zhanhui Report URL: https://github.com/apache/rocketmq-clients/actions/runs/6812188703 With regards, GitHub Actions via GitBox
[GH] (rocketmq-clients): Workflow run "Build" is working again!
The GitHub Actions job "Build" on rocketmq-clients.git has succeeded. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: 133172b1955c20d5b2cac7549dc535a0a2454a24 / Li Zhanhui fix: sync transaction_producer example Signed-off-by: Li Zhanhui Report URL: https://github.com/apache/rocketmq-clients/actions/runs/6812188705 With regards, GitHub Actions via GitBox
Re: [I] [New Feature]Is there any producer machine statistic data in plan? [rocketmq]
github-actions[bot] commented on issue #5478: URL: https://github.com/apache/rocketmq/issues/5478#issuecomment-1804869701 This issue is stale because it has been open for 365 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
[GH] (rocketmq): Workflow run "Snapshot Daily Release Automation" failed!
The GitHub Actions job "Snapshot Daily Release Automation" on rocketmq.git has failed. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: 27759f3556c279f63c13bc94fe3ad6ca8114 / Allon Murienik Fix unstable UtilAllTest#testCalculateFileSizeInPath on Windows (#7419) This patch offers an alternative approach to 5d492c338258d07613103e6ae16df4c6fa5b3838. Instead of manually setting up the directory #testCalculateFileSizeInPath needs and then recursively deleting it, it uses JUnit's TemporaryFolder Rule to handle all of this work, and allows the code to concentrate on the business logic. Closes #7418 Report URL: https://github.com/apache/rocketmq/actions/runs/6819034140 With regards, GitHub Actions via GitBox
Re: [PR] Replace lazy_static with once_cell [rocketmq-clients]
lizhanhui merged PR #636: URL: https://github.com/apache/rocketmq-clients/pull/636 -- 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: Replace lazy_static with once_cell (#636)
This is an automated email from the ASF dual-hosted git repository.
lizhanhui 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 bd9c1a11 Replace lazy_static with once_cell (#636)
bd9c1a11 is described below
commit bd9c1a11344670053aab2c818434651d571a29d4
Author: jy
AuthorDate: Fri Nov 10 10:04:41 2023 +0800
Replace lazy_static with once_cell (#636)
* Replace lazy_static with once_cell
Signed-off-by: iMXonren.Space
* fix: sync transaction_producer example
Signed-off-by: Li Zhanhui
-
Signed-off-by: iMXonren.Space
Signed-off-by: Li Zhanhui
Co-authored-by: Li Zhanhui
---
rust/Cargo.toml | 5 ++---
rust/examples/transaction_producer.rs | 5 ++---
rust/src/client.rs| 13 +
rust/src/util.rs | 11 +--
4 files changed, 14 insertions(+), 20 deletions(-)
diff --git a/rust/Cargo.toml b/rust/Cargo.toml
index 6cc106bb..da47ed29 100644
--- a/rust/Cargo.toml
+++ b/rust/Cargo.toml
@@ -36,7 +36,6 @@ tokio = { version = "1", features = ["full"] }
tokio-rustls = { version = "0.24.0", features = ["default",
"dangerous_configuration"] }
tokio-stream = "0.1.12"
async-trait = "0.1.68"
-lazy_static = "1.4"
tonic = { version = "0.9.0", features = ["tls", "default", "channel",
"tls-roots"] }
prost = "0.11.8"
prost-types = "0.11.8"
@@ -60,7 +59,7 @@ byteorder = "1"
mac_address = "1.1.4"
hex = "0.4.3"
time = "0.3"
-once_cell = "1.9.0"
+once_cell = "1.18.0"
mockall = "0.11.4"
mockall_double = "0.3.0"
@@ -82,4 +81,4 @@ awaitility = "0.3.0"
[features]
default = ["example_ack"]
example_ack = []
-example_change_invisible_duration = []
\ No newline at end of file
+example_change_invisible_duration = []
diff --git a/rust/examples/transaction_producer.rs
b/rust/examples/transaction_producer.rs
index 6df6cb65..4bc621fa 100644
--- a/rust/examples/transaction_producer.rs
+++ b/rust/examples/transaction_producer.rs
@@ -17,14 +17,13 @@
use std::collections::HashSet;
use std::sync::Mutex;
+use once_cell::sync::Lazy;
use rocketmq::conf::{ClientOption, ProducerOption};
use rocketmq::model::message::MessageBuilder;
use rocketmq::model::transaction::{Transaction, TransactionResolution};
use rocketmq::Producer;
-lazy_static::lazy_static! {
-static ref MESSAGE_ID_SET: Mutex> =
Mutex::new(HashSet::new());
-}
+static MESSAGE_ID_SET: Lazy>> = Lazy::new(||
Mutex::new(HashSet::new()));
#[tokio::main]
async fn main() {
diff --git a/rust/src/client.rs b/rust/src/client.rs
index ae034682..69000be2 100644
--- a/rust/src/client.rs
+++ b/rust/src/client.rs
@@ -21,6 +21,7 @@ use std::{collections::HashMap, sync::atomic::AtomicUsize,
sync::Arc};
use mockall::automock;
use mockall_double::double;
+use once_cell::sync::Lazy;
use parking_lot::Mutex;
use prost_types::Duration;
use slog::{debug, error, info, o, warn, Logger};
@@ -58,9 +59,7 @@ pub(crate) struct Client {
shutdown_tx: Option>,
}
-lazy_static::lazy_static! {
-static ref CLIENT_ID_SEQUENCE: AtomicUsize = AtomicUsize::new(0);
-}
+static CLIENT_ID_SEQUENCE: Lazy = Lazy::new(||
AtomicUsize::new(0));
const OPERATION_CLIENT_NEW: &str = "client.new";
const OPERATION_CLIENT_START: &str = "client.start";
@@ -698,7 +697,7 @@ pub(crate) mod tests {
use std::thread::sleep;
use std::time::Duration;
-use lazy_static::lazy_static;
+use once_cell::sync::Lazy;
use crate::client::Client;
use crate::conf::ClientOption;
@@ -717,10 +716,8 @@ pub(crate) mod tests {
use super::*;
-lazy_static! {
-// The lock is used to prevent the mocking static function at same
time during parallel testing.
-pub(crate) static ref MTX: Mutex<()> = Mutex::new(());
-}
+// The lock is used to prevent the mocking static function at same time
during parallel testing.
+pub(crate) static MTX: Lazy> = Lazy::new(|| Mutex::new(()));
fn new_client_for_test() -> Client {
Client {
diff --git a/rust/src/util.rs b/rust/src/util.rs
index 6ea92cb5..ac935b6b 100644
--- a/rust/src/util.rs
+++ b/rust/src/util.rs
@@ -14,6 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
+use once_cell::sync::Lazy;
use std::hash::Hasher;
use std::sync::atomic::Ordering;
use std::sync::Arc;
@@ -33,12 +34,10 @@ pub(crate) static SDK_LANGUAGE: Language = Language::Rust;
pub(crate) static SDK_VERSION: &str = "5.0.0";
pub(crate) static PROTOCOL_VERSION: &str = "2.0.0";
-lazy_static::lazy_static! {
-pub(crate) static ref HOST_NAME: String = match hostname::get() {
-Ok(name) => name.to_str().unwrap_or("localhost").to_string(),
-Err(_) => "localhost".to_string(),
-};
-}
+pub(crate) static HOST_NAME: Lazy = Lazy::new(|| match hostname::get()
Re: [I] 当k8s自动扩缩容，或者动态ip的时，无法自动更新connectNodeSet，导致无法通知 [rocketmq-mqtt]
pingww commented on issue #217: URL: https://github.com/apache/rocketmq-mqtt/issues/217#issuecomment-1805001010 k8s环境需要适配，可以提交一个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 For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[I] 阿里云mq 5.0系列 消息发送失败 [rocketmq-spring]
KevinWqs opened a new issue, #594: URL: https://github.com/apache/rocketmq-spring/issues/594 The issue tracker is **ONLY** used for bug report and feature request. Any question or RocketMQ proposal please use our [mailing lists](http://rocketmq.apache.org/about/contact/). **BUG REPORT** 1. Please describe the issue you observed: - What did you do (The steps to reproduce)? - What did you expect to see? - What did you see instead? 2. Please tell us about your environment: 3. Other information (e.g. detailed explanation, logs, related issues, suggestions how to fix, etc): **FEATURE REQUEST** 1. Please describe the feature you are requesting. 2. Provide any additional detail on your proposed use case for this feature. 3. Indicate the importance of this issue to you (blocker, must-have, should-have, nice-to-have). Are you currently using any workarounds to address this issue? -- 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) 01/01: let consumer be aware of message queue assignment change
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch consumer_aware_queue_change
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit 3dfe73125ac0463dc3a3968a0cfacb0a0020ae9c
Author: Li Zhanhui
AuthorDate: Fri Nov 10 15:25:58 2023 +0800
let consumer be aware of message queue assignment change
Signed-off-by: Li Zhanhui
---
.../rocketmq/client/consumer/DefaultMQPushConsumer.java | 13 +
.../org/apache/rocketmq/client/consumer/MQConsumer.java | 8 +---
.../rocketmq/client/consumer/MessageQueueListener.java | 5 ++---
.../client/impl/consumer/DefaultMQPushConsumerImpl.java | 10 +-
.../rocketmq/client/impl/consumer/RebalancePushImpl.java| 8 +++-
5 files changed, 36 insertions(+), 8 deletions(-)
diff --git
a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
index 1afb9113eb..e593a17c98 100644
---
a/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
+++
b/client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
@@ -150,6 +150,11 @@ public class DefaultMQPushConsumer extends ClientConfig
implements MQPushConsume
*/
private MessageListener messageListener;
+/**
+ * Listener to call if message queue assignment is changed.
+ */
+private MessageQueueListener messageQueueListener;
+
/**
* Offset Storage
*/
@@ -987,4 +992,12 @@ public class DefaultMQPushConsumer extends ClientConfig
implements MQPushConsume
public void setClientRebalance(boolean clientRebalance) {
this.clientRebalance = clientRebalance;
}
+
+public MessageQueueListener getMessageQueueListener() {
+return messageQueueListener;
+}
+
+public void setMessageQueueListener(MessageQueueListener
messageQueueListener) {
+this.messageQueueListener = messageQueueListener;
+}
}
diff --git
a/client/src/main/java/org/apache/rocketmq/client/consumer/MQConsumer.java
b/client/src/main/java/org/apache/rocketmq/client/consumer/MQConsumer.java
index f4a8eda23a..81e06ee417 100644
--- a/client/src/main/java/org/apache/rocketmq/client/consumer/MQConsumer.java
+++ b/client/src/main/java/org/apache/rocketmq/client/consumer/MQConsumer.java
@@ -29,20 +29,22 @@ import
org.apache.rocketmq.remoting.exception.RemotingException;
*/
public interface MQConsumer extends MQAdmin {
/**
- * If consuming failure,message will be send back to the brokers,and delay
consuming some time
+ * If consuming of messages failed, they will be sent back to the brokers
for another delivery attempt after
+ * interval specified in delay level.
*/
@Deprecated
void sendMessageBack(final MessageExt msg, final int delayLevel) throws
RemotingException,
MQBrokerException, InterruptedException, MQClientException;
/**
- * If consuming failure,message will be send back to the broker,and delay
consuming some time
+ * If consuming of messages failed, they will be sent back to the brokers
for another delivery attempt after
+ * interval specified in delay level.
*/
void sendMessageBack(final MessageExt msg, final int delayLevel, final
String brokerName)
throws RemotingException, MQBrokerException, InterruptedException,
MQClientException;
/**
- * Fetch message queues from consumer cache according to the topic
+ * Fetch message queues from consumer cache pertaining to the given topic.
*
* @param topic message topic
* @return queue set
diff --git
a/client/src/main/java/org/apache/rocketmq/client/consumer/MessageQueueListener.java
b/client/src/main/java/org/apache/rocketmq/client/consumer/MessageQueueListener.java
index 63795a6eeb..74510f4c3e 100644
---
a/client/src/main/java/org/apache/rocketmq/client/consumer/MessageQueueListener.java
+++
b/client/src/main/java/org/apache/rocketmq/client/consumer/MessageQueueListener.java
@@ -26,8 +26,7 @@ public interface MessageQueueListener {
/**
* @param topic message topic
* @param mqAll all queues in this message topic
- * @param mqDivided collection of queues,assigned to the current consumer
+ * @param mqAssigned collection of queues, assigned to the current consumer
*/
-void messageQueueChanged(final String topic, final Set mqAll,
-final Set mqDivided);
+void messageQueueChanged(final String topic, final Set
mqAll, final Set mqAssigned);
}
diff --git
a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
index e57579321c..cfb89b5c88 100644
---
a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
+++
b/cli
(rocketmq) branch consumer_aware_queue_change created (now 3dfe73125a)
This is an automated email from the ASF dual-hosted git repository. lizhanhui pushed a change to branch consumer_aware_queue_change in repository https://gitbox.apache.org/repos/asf/rocketmq.git at 3dfe73125a let consumer be aware of message queue assignment change This branch includes the following new commits: new 3dfe73125a let consumer be aware of message queue assignment change 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.
[I] [Enhancement] Let PushConsumer client aware of message queue assignment change [rocketmq]
lizhanhui opened a new issue, #7547: URL: https://github.com/apache/rocketmq/issues/7547 ### Before Creating the Enhancement Request - [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature. ### Summary Allowing consumer client is being aware of the message queue assignment change is essential to log key events and fix flaky integration tests. ### Motivation Allowing consumer client is being aware of the message queue assignment change is essential to log key events and fix flaky integration tests. ### Describe the Solution You'd Like Expose rebalance results via existing MessageQueueListener API ### Describe Alternatives You've Considered N/A ### Additional Context _No response_ -- 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] let consumer be aware of message queue assignment change [rocketmq]
lizhanhui opened a new pull request, #7548: URL: https://github.com/apache/rocketmq/pull/7548 fix #7547 -- 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] 阿里云mq 5.0系列 消息发送失败 [rocketmq-spring]
KevinWqs commented on issue #594: URL: https://github.com/apache/rocketmq-spring/issues/594#issuecomment-1805236029 已经解决，需要配置 access-key secret-key -- 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] 阿里云mq 5.0系列 消息发送失败 [rocketmq-spring]
KevinWqs closed issue #594: 阿里云mq 5.0系列 消息发送失败 URL: https://github.com/apache/rocketmq-spring/issues/594 -- 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 Bazel" failed!
The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has failed. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: 3dfe73125ac0463dc3a3968a0cfacb0a0020ae9c / Li Zhanhui let consumer be aware of message queue assignment change Signed-off-by: Li Zhanhui Report URL: https://github.com/apache/rocketmq/actions/runs/6822002005 With regards, GitHub Actions via GitBox
(rocketmq) branch consumer_aware_queue_change updated: add unit test for DefaultMQPushConsumer#setMessageQueueListener
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch consumer_aware_queue_change
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/consumer_aware_queue_change by
this push:
new 974c765882 add unit test for
DefaultMQPushConsumer#setMessageQueueListener
974c765882 is described below
commit 974c7658828fb70028de6ecdd2966b3ad638a2ed
Author: Li Zhanhui
AuthorDate: Fri Nov 10 15:42:23 2023 +0800
add unit test for DefaultMQPushConsumer#setMessageQueueListener
Signed-off-by: Li Zhanhui
---
.../consumer/balance/NormalMsgDynamicBalanceIT.java | 20
1 file changed, 20 insertions(+)
diff --git
a/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgDynamicBalanceIT.java
b/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgDynamicBalanceIT.java
index b2c9b06589..9bcd2a5ce2 100644
---
a/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgDynamicBalanceIT.java
+++
b/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgDynamicBalanceIT.java
@@ -17,6 +17,11 @@
package org.apache.rocketmq.test.client.consumer.balance;
+import java.util.Set;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+import org.apache.rocketmq.client.consumer.MessageQueueListener;
+import org.apache.rocketmq.common.message.MessageQueue;
import org.apache.rocketmq.logging.org.slf4j.Logger;
import org.apache.rocketmq.logging.org.slf4j.LoggerFactory;
import org.apache.rocketmq.test.base.BaseConf;
@@ -112,4 +117,19 @@ public class NormalMsgDynamicBalanceIT extends BaseConf {
consumer2.getListener().getAllUndupMsgBody()).size());
assertThat(balance).isEqualTo(true);
}
+
+@Test
+public void testMessageQueueListener() throws InterruptedException {
+final CountDownLatch latch = new CountDownLatch(1);
+
+RMQNormalConsumer consumer1 = getConsumer(NAMESRV_ADDR, topic, "*",
new RMQNormalListener());
+// Register message queue listener
+consumer1.getConsumer().setMessageQueueListener((topic, mqAll,
mqAssigned) -> latch.countDown());
+
+// Without message queue listener
+RMQNormalConsumer consumer2 = getConsumer(NAMESRV_ADDR,
consumer1.getConsumerGroup(), topic,
+"*", new RMQNormalListener());
+
+Assert.assertTrue(latch.await(30, TimeUnit.SECONDS));
+}
}
[GH] (rocketmq): Workflow run "PR-CI" failed!
The GitHub Actions job "PR-CI" on rocketmq.git has failed. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: 974c7658828fb70028de6ecdd2966b3ad638a2ed / Li Zhanhui add unit test for DefaultMQPushConsumer#setMessageQueueListener Signed-off-by: Li Zhanhui Report URL: https://github.com/apache/rocketmq/actions/runs/6822073590 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "E2E test for pull request" failed!
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: 27759f3556c279f63c13bc94fe3ad6ca8114 / Allon Murienik Fix unstable UtilAllTest#testCalculateFileSizeInPath on Windows (#7419) This patch offers an alternative approach to 5d492c338258d07613103e6ae16df4c6fa5b3838. Instead of manually setting up the directory #testCalculateFileSizeInPath needs and then recursively deleting it, it uses JUnit's TemporaryFolder Rule to handle all of this work, and allows the code to concentrate on the business logic. Closes #7418 Report URL: https://github.com/apache/rocketmq/actions/runs/6822085187 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "E2E test for pull request" failed!
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: 27759f3556c279f63c13bc94fe3ad6ca8114 / Allon Murienik Fix unstable UtilAllTest#testCalculateFileSizeInPath on Windows (#7419) This patch offers an alternative approach to 5d492c338258d07613103e6ae16df4c6fa5b3838. Instead of manually setting up the directory #testCalculateFileSizeInPath needs and then recursively deleting it, it uses JUnit's TemporaryFolder Rule to handle all of this work, and allows the code to concentrate on the business logic. Closes #7418 Report URL: https://github.com/apache/rocketmq/actions/runs/6822025077 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Coverage" failed!
The GitHub Actions job "Coverage" on rocketmq.git has failed. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: 974c7658828fb70028de6ecdd2966b3ad638a2ed / Li Zhanhui add unit test for DefaultMQPushConsumer#setMessageQueueListener Signed-off-by: Li Zhanhui Report URL: https://github.com/apache/rocketmq/actions/runs/6822073588 With regards, GitHub Actions via GitBox
(rocketmq) branch consumer_aware_queue_change updated: allow cache bazel test results
This is an automated email from the ASF dual-hosted git repository. lizhanhui pushed a commit to branch consumer_aware_queue_change in repository https://gitbox.apache.org/repos/asf/rocketmq.git The following commit(s) were added to refs/heads/consumer_aware_queue_change by this push: new e0e9589485 allow cache bazel test results e0e9589485 is described below commit e0e9589485361647456477115be305feb7de2057 Author: Li Zhanhui AuthorDate: Fri Nov 10 15:50:20 2023 +0800 allow cache bazel test results Signed-off-by: Li Zhanhui --- .github/workflows/bazel.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/.github/workflows/bazel.yml b/.github/workflows/bazel.yml index 7652b93048..af674592bb 100644 --- a/.github/workflows/bazel.yml +++ b/.github/workflows/bazel.yml @@ -19,4 +19,4 @@ jobs: - name: Build run: bazel build --config=remote //... - name: Run Tests -run: bazel test --config=remote --nocache_test_results //... \ No newline at end of file +run: bazel test --config=remote //... \ No newline at end of file
(rocketmq) branch consumer_aware_queue_change updated (974c765882 -> 8258eddff8)
This is an automated email from the ASF dual-hosted git repository. lizhanhui pushed a change to branch consumer_aware_queue_change in repository https://gitbox.apache.org/repos/asf/rocketmq.git from 974c765882 add unit test for DefaultMQPushConsumer#setMessageQueueListener add 96abfdf188 fix: bazel build warnings add 8258eddff8 fix: set MixCommitlogTest test size as medium No new revisions were added by this update. Summary of changes: remoting/BUILD.bazel| 1 + store/BUILD.bazel | 1 + tieredstore/BUILD.bazel | 1 + tools/BUILD.bazel | 1 + 4 files changed, 4 insertions(+)
[GH] (rocketmq): Workflow run "E2E test for pull request" failed!
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: 27759f3556c279f63c13bc94fe3ad6ca8114 / Allon Murienik Fix unstable UtilAllTest#testCalculateFileSizeInPath on Windows (#7419) This patch offers an alternative approach to 5d492c338258d07613103e6ae16df4c6fa5b3838. Instead of manually setting up the directory #testCalculateFileSizeInPath needs and then recursively deleting it, it uses JUnit's TemporaryFolder Rule to handle all of this work, and allows the code to concentrate on the business logic. Closes #7418 Report URL: https://github.com/apache/rocketmq/actions/runs/6822137154 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "PR-CI" failed!
The GitHub Actions job "PR-CI" on rocketmq.git has failed. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: e0e9589485361647456477115be305feb7de2057 / Li Zhanhui allow cache bazel test results Signed-off-by: Li Zhanhui Report URL: https://github.com/apache/rocketmq/actions/runs/6822130712 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "PR-CI" failed!
The GitHub Actions job "PR-CI" on rocketmq.git has failed. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: 8258eddff826e430bc7c51e0a10dcb16734ef767 / Zhanhui Li fix: set MixCommitlogTest test size as medium Signed-off-by: Zhanhui Li Report URL: https://github.com/apache/rocketmq/actions/runs/6822123859 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Build and Run Tests by Bazel" failed!
The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has failed. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: 974c7658828fb70028de6ecdd2966b3ad638a2ed / Li Zhanhui add unit test for DefaultMQPushConsumer#setMessageQueueListener Signed-off-by: Li Zhanhui Report URL: https://github.com/apache/rocketmq/actions/runs/6822073589 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "E2E test for pull request" failed!
The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: 27759f3556c279f63c13bc94fe3ad6ca8114 / Allon Murienik Fix unstable UtilAllTest#testCalculateFileSizeInPath on Windows (#7419) This patch offers an alternative approach to 5d492c338258d07613103e6ae16df4c6fa5b3838. Instead of manually setting up the directory #testCalculateFileSizeInPath needs and then recursively deleting it, it uses JUnit's TemporaryFolder Rule to handle all of this work, and allows the code to concentrate on the business logic. Closes #7418 Report URL: https://github.com/apache/rocketmq/actions/runs/6822143999 With regards, GitHub Actions via GitBox
(rocketmq) branch consumer_aware_queue_change updated: fix code style issue by removing unused imports
This is an automated email from the ASF dual-hosted git repository. lizhanhui pushed a commit to branch consumer_aware_queue_change in repository https://gitbox.apache.org/repos/asf/rocketmq.git The following commit(s) were added to refs/heads/consumer_aware_queue_change by this push: new f74c8874ee fix code style issue by removing unused imports f74c8874ee is described below commit f74c8874ee341c80a47e0906a0de245d8446f8ac Author: Li Zhanhui AuthorDate: Fri Nov 10 15:54:18 2023 +0800 fix code style issue by removing unused imports Signed-off-by: Li Zhanhui --- .../test/client/consumer/balance/NormalMsgDynamicBalanceIT.java| 3 --- 1 file changed, 3 deletions(-) diff --git a/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgDynamicBalanceIT.java b/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgDynamicBalanceIT.java index 9bcd2a5ce2..684b718ae5 100644 --- a/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgDynamicBalanceIT.java +++ b/test/src/test/java/org/apache/rocketmq/test/client/consumer/balance/NormalMsgDynamicBalanceIT.java @@ -17,11 +17,8 @@ package org.apache.rocketmq.test.client.consumer.balance; -import java.util.Set; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; -import org.apache.rocketmq.client.consumer.MessageQueueListener; -import org.apache.rocketmq.common.message.MessageQueue; import org.apache.rocketmq.logging.org.slf4j.Logger; import org.apache.rocketmq.logging.org.slf4j.LoggerFactory; import org.apache.rocketmq.test.base.BaseConf;
[GH] (rocketmq): Workflow run "Build and Run Tests by Bazel" failed!
The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has failed. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: 8258eddff826e430bc7c51e0a10dcb16734ef767 / Zhanhui Li fix: set MixCommitlogTest test size as medium Signed-off-by: Zhanhui Li Report URL: https://github.com/apache/rocketmq/actions/runs/6822123858 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Build and Run Tests by Bazel" failed!
The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has failed. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: e0e9589485361647456477115be305feb7de2057 / Li Zhanhui allow cache bazel test results Signed-off-by: Li Zhanhui Report URL: https://github.com/apache/rocketmq/actions/runs/6822130710 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Coverage" failed!
The GitHub Actions job "Coverage" on rocketmq.git has failed. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: 3dfe73125ac0463dc3a3968a0cfacb0a0020ae9c / Li Zhanhui let consumer be aware of message queue assignment change Signed-off-by: Li Zhanhui Report URL: https://github.com/apache/rocketmq/actions/runs/6822002008 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "PR-CI" is working again!
The GitHub Actions job "PR-CI" on rocketmq.git has succeeded. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: f74c8874ee341c80a47e0906a0de245d8446f8ac / Li Zhanhui fix code style issue by removing unused imports Signed-off-by: Li Zhanhui Report URL: https://github.com/apache/rocketmq/actions/runs/6822159203 With regards, GitHub Actions via GitBox
[GH] (rocketmq): Workflow run "Build and Run Tests by Bazel" failed!
The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has failed. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: f74c8874ee341c80a47e0906a0de245d8446f8ac / Li Zhanhui fix code style issue by removing unused imports Signed-off-by: Li Zhanhui Report URL: https://github.com/apache/rocketmq/actions/runs/6822159204 With regards, GitHub Actions via GitBox
