[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" failed!

2024-01-24 Thread GitBox


The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has 
failed.
Run started by GitHub user drpmma (triggered by drpmma).

Head commit for run:
14b57fd05b8add1db9413409ea76e81a2bef8c00 / zhouxiang 

Get namespace from header

Report URL: https://github.com/apache/rocketmq/actions/runs/7634761912

With regards,
GitHub Actions via GitBox



(rocketmq-exporter) annotated tag rocketmq-exporter-0.0.2 deleted (was 13337b3)

2024-01-24 Thread jinrongtong
This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a change to annotated tag rocketmq-exporter-0.0.2
in repository https://gitbox.apache.org/repos/asf/rocketmq-exporter.git


*** WARNING: tag rocketmq-exporter-0.0.2 was deleted! ***

   tag was  13337b3

The revisions that were on this annotated tag are still contained in
other references; therefore, this change does not discard any commits
from the repository.



(rocketmq-exporter) branch pre-release-0.0.2 updated (74e0131 -> 25c1138)

2024-01-24 Thread jinrongtong
This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a change to branch pre-release-0.0.2
in repository https://gitbox.apache.org/repos/asf/rocketmq-exporter.git


 discard 74e0131  [maven-release-plugin] prepare for next development iteration
 discard 620ed83  [maven-release-plugin] prepare release rocketmq-exporter-0.0.2

This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.

 * -- * -- N   refs/heads/pre-release-0.0.2 (25c1138)
\
 O -- O -- O   (74e0131)

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:
 pom.xml | 9 +
 1 file changed, 5 insertions(+), 4 deletions(-)



(rocketmq-exporter) branch pre-release-0.0.2 updated: Add distributionManagement block

2024-01-24 Thread jinrongtong
This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch pre-release-0.0.2
in repository https://gitbox.apache.org/repos/asf/rocketmq-exporter.git


The following commit(s) were added to refs/heads/pre-release-0.0.2 by this push:
 new eee8a1b  Add distributionManagement block
eee8a1b is described below

commit eee8a1bbc9da09ce219e75d3155d35867a938998
Author: RongtongJin 
AuthorDate: Wed Jan 24 18:42:01 2024 +0800

Add distributionManagement block
---
 pom.xml | 13 +
 1 file changed, 13 insertions(+)

diff --git a/pom.xml b/pom.xml
index e8b3ace..4176886 100644
--- a/pom.xml
+++ b/pom.xml
@@ -15,6 +15,19 @@
 
 Apache RocketMQ Prometheus Exporter
 
+
+
+apache.releases.https
+Apache Release Distribution Repository
+
https://repository.apache.org/service/local/staging/deploy/maven2
+
+
+apache.snapshots.https
+Apache Development Snapshot Repository
+
https://repository.apache.org/content/repositories/snapshots
+
+
+
 
 g...@github.com:apache/rocketmq-exporter.git
 
scm:git:g...@github.com:apache/rocketmq-exporter.git



(rocketmq-exporter) branch pre-release-0.0.2 updated: [maven-release-plugin] prepare release rocketmq-exporter-0.0.2

2024-01-24 Thread jinrongtong
This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch pre-release-0.0.2
in repository https://gitbox.apache.org/repos/asf/rocketmq-exporter.git


The following commit(s) were added to refs/heads/pre-release-0.0.2 by this push:
 new d4f5708  [maven-release-plugin] prepare release rocketmq-exporter-0.0.2
d4f5708 is described below

commit d4f57087cad7e64e3d0ce0b6489fdad5f7fd4a30
Author: RongtongJin 
AuthorDate: Wed Jan 24 18:42:54 2024 +0800

[maven-release-plugin] prepare release rocketmq-exporter-0.0.2
---
 pom.xml | 11 +--
 1 file changed, 5 insertions(+), 6 deletions(-)

diff --git a/pom.xml b/pom.xml
index 4176886..7b854f6 100644
--- a/pom.xml
+++ b/pom.xml
@@ -1,16 +1,15 @@
 
-http://maven.apache.org/POM/4.0.0"; 
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+http://maven.apache.org/POM/4.0.0"; 
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; 
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
 4.0.0
 
 org.springframework.boot
 spring-boot-starter-parent
 2.7.11
- 
+ 
 
 org.apache
 rocketmq-exporter
-0.0.2-SNAPSHOT
+0.0.2
 rocketmq-exporter
 
 Apache RocketMQ Prometheus Exporter
@@ -32,7 +31,7 @@
 g...@github.com:apache/rocketmq-exporter.git
 
scm:git:g...@github.com:apache/rocketmq-exporter.git
 
scm:git:g...@github.com:apache/rocketmq-exporter.git
-HEAD
+rocketmq-exporter-0.0.2
 
 
 
@@ -193,7 +192,7 @@
 html
 xml
 
-
+
 
 
 



(rocketmq-exporter) annotated tag rocketmq-exporter-0.0.2 updated (d4f5708 -> 2d26475)

2024-01-24 Thread jinrongtong
This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a change to annotated tag rocketmq-exporter-0.0.2
in repository https://gitbox.apache.org/repos/asf/rocketmq-exporter.git


*** WARNING: tag rocketmq-exporter-0.0.2 was modified! ***

from d4f5708  (commit)
  to 2d26475  (tag)
 tagging d4f57087cad7e64e3d0ce0b6489fdad5f7fd4a30 (commit)
 replaces v0.0.2-rc1
  by RongtongJin
  on Wed Jan 24 18:43:07 2024 +0800

- Log -
[maven-release-plugin] copy for tag rocketmq-exporter-0.0.2
---


No new revisions were added by this update.

Summary of changes:



(rocketmq-exporter) branch pre-release-0.0.2 updated: [maven-release-plugin] prepare for next development iteration

2024-01-24 Thread jinrongtong
This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch pre-release-0.0.2
in repository https://gitbox.apache.org/repos/asf/rocketmq-exporter.git


The following commit(s) were added to refs/heads/pre-release-0.0.2 by this push:
 new 10c749a  [maven-release-plugin] prepare for next development iteration
10c749a is described below

commit 10c749a5e05db6f9201abe3d1e8a0db6a1d231da
Author: RongtongJin 
AuthorDate: Wed Jan 24 18:43:13 2024 +0800

[maven-release-plugin] prepare for next development iteration
---
 pom.xml | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/pom.xml b/pom.xml
index 7b854f6..202b204 100644
--- a/pom.xml
+++ b/pom.xml
@@ -9,7 +9,7 @@
 
 org.apache
 rocketmq-exporter
-0.0.2
+0.0.3-SNAPSHOT
 rocketmq-exporter
 
 Apache RocketMQ Prometheus Exporter
@@ -31,7 +31,7 @@
 g...@github.com:apache/rocketmq-exporter.git
 
scm:git:g...@github.com:apache/rocketmq-exporter.git
 
scm:git:g...@github.com:apache/rocketmq-exporter.git
-rocketmq-exporter-0.0.2
+HEAD
 
 
 



[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" is working again!

2024-01-24 Thread GitBox


The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has 
succeeded.
Run started by GitHub user drpmma (triggered by drpmma).

Head commit for run:
14b57fd05b8add1db9413409ea76e81a2bef8c00 / zhouxiang 

Get namespace from header

Report URL: https://github.com/apache/rocketmq/actions/runs/7634761912

With regards,
GitHub Actions via GitBox



Re: [PR] [ISSUE #7781] Get namespace from gRPC header [rocketmq]

2024-01-24 Thread via GitHub


drpmma merged PR #7782:
URL: https://github.com/apache/rocketmq/pull/7782


-- 
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] [Enhancement] Get namespace from gRPC header [rocketmq]

2024-01-24 Thread via GitHub


drpmma closed issue #7781: [Enhancement] Get namespace from gRPC header 
URL: https://github.com/apache/rocketmq/issues/7781


-- 
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) branch develop updated: Get namespace from header (#7782)

2024-01-24 Thread zhouxzhan
This is an automated email from the ASF dual-hosted git repository.

zhouxzhan pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
 new 04eec34978 Get namespace from header (#7782)
04eec34978 is described below

commit 04eec3497895a1fa8a9c8fbe520406c62a05a5b0
Author: Zhouxiang Zhan 
AuthorDate: Wed Jan 24 20:18:59 2024 +0800

Get namespace from header (#7782)
---
 .../java/org/apache/rocketmq/proxy/common/ContextVariable.java   | 2 +-
 .../main/java/org/apache/rocketmq/proxy/common/ProxyContext.java | 9 +
 .../apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java  | 3 ++-
 3 files changed, 12 insertions(+), 2 deletions(-)

diff --git 
a/proxy/src/main/java/org/apache/rocketmq/proxy/common/ContextVariable.java 
b/proxy/src/main/java/org/apache/rocketmq/proxy/common/ContextVariable.java
index 0760826de7..93b4eacd8a 100644
--- a/proxy/src/main/java/org/apache/rocketmq/proxy/common/ContextVariable.java
+++ b/proxy/src/main/java/org/apache/rocketmq/proxy/common/ContextVariable.java
@@ -27,5 +27,5 @@ public class ContextVariable {
 public static final String REMAINING_MS = "remaining-ms";
 public static final String ACTION = "action";
 public static final String PROTOCOL_TYPE = "protocol-type";
-
+public static final String NAMESPACE = "namespace";
 }
diff --git 
a/proxy/src/main/java/org/apache/rocketmq/proxy/common/ProxyContext.java 
b/proxy/src/main/java/org/apache/rocketmq/proxy/common/ProxyContext.java
index 77a6791f04..e6fc989fcc 100644
--- a/proxy/src/main/java/org/apache/rocketmq/proxy/common/ProxyContext.java
+++ b/proxy/src/main/java/org/apache/rocketmq/proxy/common/ProxyContext.java
@@ -131,4 +131,13 @@ public class ProxyContext {
 return this.getVal(ContextVariable.PROTOCOL_TYPE);
 }
 
+public ProxyContext setNamespace(String namespace) {
+this.withVal(ContextVariable.NAMESPACE, namespace);
+return this;
+}
+
+public String getNamespace() {
+return this.getVal(ContextVariable.NAMESPACE);
+}
+
 }
diff --git 
a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java
 
b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java
index 2cb395ad60..a344b0590c 100644
--- 
a/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java
+++ 
b/proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java
@@ -175,7 +175,8 @@ public class GrpcMessagingApplication extends 
MessagingServiceGrpc.MessagingServ
 .setProtocolType(ChannelProtocolType.GRPC_V2.getName())
 .setLanguage(getDefaultStringMetadataInfo(headers, 
InterceptorConstants.LANGUAGE))
 .setClientVersion(getDefaultStringMetadataInfo(headers, 
InterceptorConstants.CLIENT_VERSION))
-.setAction(getDefaultStringMetadataInfo(headers, 
InterceptorConstants.SIMPLE_RPC_NAME));
+.setAction(getDefaultStringMetadataInfo(headers, 
InterceptorConstants.SIMPLE_RPC_NAME))
+.setNamespace(getDefaultStringMetadataInfo(headers, 
InterceptorConstants.NAMESPACE_ID));
 if (ctx.getDeadline() != null) {
 
context.setRemainingMs(ctx.getDeadline().timeRemaining(TimeUnit.MILLISECONDS));
 }



[GH] (rocketmq): Workflow run "Build and Run Tests by Bazel" failed!

2024-01-24 Thread GitBox


The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has 
failed.
Run started by GitHub user drpmma (triggered by drpmma).

Head commit for run:
04eec3497895a1fa8a9c8fbe520406c62a05a5b0 / Zhouxiang Zhan 

Get namespace from header (#7782)

Report URL: https://github.com/apache/rocketmq/actions/runs/7640050782

With regards,
GitHub Actions via GitBox



(rocketmq-exporter) annotated tag rocketmq-exporter-0.0.2 deleted (was 2d26475)

2024-01-24 Thread jinrongtong
This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a change to annotated tag rocketmq-exporter-0.0.2
in repository https://gitbox.apache.org/repos/asf/rocketmq-exporter.git


*** WARNING: tag rocketmq-exporter-0.0.2 was deleted! ***

   tag was  2d26475

The revisions that were on this annotated tag are still contained in
other references; therefore, this change does not discard any commits
from the repository.



(rocketmq-exporter) branch pre-release-0.0.2 updated (10c749a -> 25c1138)

2024-01-24 Thread jinrongtong
This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a change to branch pre-release-0.0.2
in repository https://gitbox.apache.org/repos/asf/rocketmq-exporter.git


 discard 10c749a  [maven-release-plugin] prepare for next development iteration
 discard d4f5708  [maven-release-plugin] prepare release rocketmq-exporter-0.0.2
 discard eee8a1b  Add distributionManagement block

This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.

 * -- * -- N   refs/heads/pre-release-0.0.2 (25c1138)
\
 O -- O -- O   (10c749a)

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:
 pom.xml | 22 +-
 1 file changed, 5 insertions(+), 17 deletions(-)



[GH] (rocketmq): Workflow run "PUSH-CI" failed!

2024-01-24 Thread GitBox


The GitHub Actions job "PUSH-CI" on rocketmq.git has failed.
Run started by GitHub user drpmma (triggered by drpmma).

Head commit for run:
04eec3497895a1fa8a9c8fbe520406c62a05a5b0 / Zhouxiang Zhan 

Get namespace from header (#7782)

Report URL: https://github.com/apache/rocketmq/actions/runs/7640050795

With regards,
GitHub Actions via GitBox



(rocketmq-exporter) branch pre-release-0.0.2 updated: Replace parent with Apache

2024-01-24 Thread jinrongtong
This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch pre-release-0.0.2
in repository https://gitbox.apache.org/repos/asf/rocketmq-exporter.git


The following commit(s) were added to refs/heads/pre-release-0.0.2 by this push:
 new 3859e4f  Replace parent with Apache
3859e4f is described below

commit 3859e4fe54fef92126850381575e942c18f721d3
Author: RongtongJin 
AuthorDate: Wed Jan 24 20:38:23 2024 +0800

Replace parent with Apache
---
 pom.xml | 42 +-
 1 file changed, 37 insertions(+), 5 deletions(-)

diff --git a/pom.xml b/pom.xml
index e8b3ace..0fcfa18 100644
--- a/pom.xml
+++ b/pom.xml
@@ -2,12 +2,18 @@
 http://maven.apache.org/POM/4.0.0"; 
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
 4.0.0
+
+
+
+
+
+
 
-org.springframework.boot
-spring-boot-starter-parent
-2.7.11
- 
+org.apache
+apache
+31
 
+
 org.apache
 rocketmq-exporter
 0.0.2-SNAPSHOT
@@ -22,11 +28,29 @@
 HEAD
 
 
+
 
 4.9.4
 docker.io
+1.8
+@
+${java.version}
+${java.version}
+2.7.11
 
 
+
+
+
+org.springframework.boot
+spring-boot-dependencies
+${spring-boot.version}
+pom
+import
+
+
+
+
 
 
 com.google.guava
@@ -93,9 +117,17 @@
 
 org.springframework.boot
 spring-boot-maven-plugin
+${spring-boot.version}
 
 exec
 
+
+
+
+repackage
+
+
+
 
 
 org.apache.maven.plugins
@@ -187,4 +219,4 @@
 
 
 
-
+
\ No newline at end of file



(rocketmq-exporter) branch pre-release-0.0.2 updated: [maven-release-plugin] prepare release rocketmq-exporter-0.0.2

2024-01-24 Thread jinrongtong
This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch pre-release-0.0.2
in repository https://gitbox.apache.org/repos/asf/rocketmq-exporter.git


The following commit(s) were added to refs/heads/pre-release-0.0.2 by this push:
 new 98c1dee  [maven-release-plugin] prepare release rocketmq-exporter-0.0.2
98c1dee is described below

commit 98c1deec91b7d38901dc79b267a7e584641eee57
Author: RongtongJin 
AuthorDate: Wed Jan 24 20:48:37 2024 +0800

[maven-release-plugin] prepare release rocketmq-exporter-0.0.2
---
 pom.xml | 9 -
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git a/pom.xml b/pom.xml
index 0fcfa18..244d23e 100644
--- a/pom.xml
+++ b/pom.xml
@@ -1,6 +1,5 @@
 
-http://maven.apache.org/POM/4.0.0"; 
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
- xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
+http://maven.apache.org/POM/4.0.0"; 
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; 
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
http://maven.apache.org/xsd/maven-4.0.0.xsd";>
 4.0.0
 
 
@@ -16,7 +15,7 @@
 
 org.apache
 rocketmq-exporter
-0.0.2-SNAPSHOT
+0.0.2
 rocketmq-exporter
 
 Apache RocketMQ Prometheus Exporter
@@ -25,7 +24,7 @@
 g...@github.com:apache/rocketmq-exporter.git
 
scm:git:g...@github.com:apache/rocketmq-exporter.git
 
scm:git:g...@github.com:apache/rocketmq-exporter.git
-HEAD
+rocketmq-exporter-0.0.2
 
 
 
@@ -212,7 +211,7 @@
 html
 xml
 
-
+
 
 
 



(rocketmq-exporter) annotated tag rocketmq-exporter-0.0.2 updated (98c1dee -> 4bfab62)

2024-01-24 Thread jinrongtong
This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a change to annotated tag rocketmq-exporter-0.0.2
in repository https://gitbox.apache.org/repos/asf/rocketmq-exporter.git


*** WARNING: tag rocketmq-exporter-0.0.2 was modified! ***

from 98c1dee  (commit)
  to 4bfab62  (tag)
 tagging 98c1deec91b7d38901dc79b267a7e584641eee57 (commit)
 replaces v0.0.2-rc1
  by RongtongJin
  on Wed Jan 24 20:48:58 2024 +0800

- Log -
[maven-release-plugin] copy for tag rocketmq-exporter-0.0.2
---


No new revisions were added by this update.

Summary of changes:



(rocketmq-exporter) branch pre-release-0.0.2 updated: [maven-release-plugin] prepare for next development iteration

2024-01-24 Thread jinrongtong
This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch pre-release-0.0.2
in repository https://gitbox.apache.org/repos/asf/rocketmq-exporter.git


The following commit(s) were added to refs/heads/pre-release-0.0.2 by this push:
 new 9e898f7  [maven-release-plugin] prepare for next development iteration
9e898f7 is described below

commit 9e898f7e63a7bf68d3eaac2740fdb000a5406625
Author: RongtongJin 
AuthorDate: Wed Jan 24 20:50:19 2024 +0800

[maven-release-plugin] prepare for next development iteration
---
 pom.xml | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/pom.xml b/pom.xml
index 244d23e..7655e41 100644
--- a/pom.xml
+++ b/pom.xml
@@ -15,7 +15,7 @@
 
 org.apache
 rocketmq-exporter
-0.0.2
+0.0.3-SNAPSHOT
 rocketmq-exporter
 
 Apache RocketMQ Prometheus Exporter
@@ -24,7 +24,7 @@
 g...@github.com:apache/rocketmq-exporter.git
 
scm:git:g...@github.com:apache/rocketmq-exporter.git
 
scm:git:g...@github.com:apache/rocketmq-exporter.git
-rocketmq-exporter-0.0.2
+HEAD
 
 
 



Re: [I] [Bug] messages will permanently send to other broker when enable sendLatencyFault [rocketmq]

2024-01-24 Thread via GitHub


RongtongJin commented on issue #7779:
URL: https://github.com/apache/rocketmq/issues/7779#issuecomment-1909211521

   @Tcytw Good catch! Could you submit a pull reqeust to fix the 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

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org



Re: [I] [Bug] messages will permanently send to other broker when enable sendLatencyFault [rocketmq]

2024-01-24 Thread via GitHub


leizhiyuan commented on issue #7779:
URL: https://github.com/apache/rocketmq/issues/7779#issuecomment-1909250426

   https://github.com/apache/rocketmq/pull/7716 @RongtongJin  


-- 
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] [ISSUE #202 #159]when the broker uses hostNetwork, the IP registered by the broker to the nameserver is not the podIP [rocketmq-operator]

2024-01-24 Thread via GitHub


usernameisnull commented on PR #203:
URL: 
https://github.com/apache/rocketmq-operator/pull/203#issuecomment-1909253674

   PTAL @caigy


-- 
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] fix the selectOneMessageQueue to avoid change messageQueue permanently [rocketmq]

2024-01-24 Thread via GitHub


Tcytw opened a new pull request, #7783:
URL: https://github.com/apache/rocketmq/pull/7783

   
   
   ### Which Issue(s) This PR Fixes
   
   
   
   Fixes #7779 
   
   ### Brief Description
   
   
   
   when selectOneMessageQueue, return clone object instead of the original 
messageQueue
   
   ### 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



Re: [I] [Bug] messages will permanently send to other broker when enable sendLatencyFault [rocketmq]

2024-01-24 Thread via GitHub


Tcytw commented on issue #7779:
URL: https://github.com/apache/rocketmq/issues/7779#issuecomment-1909300066

   > @Tcytw Good catch! Could you submit a pull reqeust to fix the issue?
   
   Of course.  I have submit the pull request at  
https://github.com/apache/rocketmq/pull/7783


-- 
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!

2024-01-24 Thread GitBox


The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has 
failed.
Run started by GitHub user dingshuangxi888 (triggered by dingshuangxi888).

Head commit for run:
c0012d40af35363a8913559898daea4c1b871193 / ShuangxiDing 

merge master

Report URL: https://github.com/apache/rocketmq/actions/runs/7649666955

With regards,
GitHub Actions via GitBox



[GH] (rocketmq): Workflow run "E2E test for pull request" failed!

2024-01-24 Thread GitBox


The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed.
Run started by GitHub user dingshuangxi888 (triggered by dingshuangxi888).

Head commit for run:
04eec3497895a1fa8a9c8fbe520406c62a05a5b0 / Zhouxiang Zhan 

Get namespace from header (#7782)

Report URL: https://github.com/apache/rocketmq/actions/runs/7649695546

With regards,
GitHub Actions via GitBox



[GH] (rocketmq): Workflow run "Coverage" failed!

2024-01-24 Thread GitBox


The GitHub Actions job "Coverage" on rocketmq.git has failed.
Run started by GitHub user dingshuangxi888 (triggered by dingshuangxi888).

Head commit for run:
c0012d40af35363a8913559898daea4c1b871193 / ShuangxiDing 

merge master

Report URL: https://github.com/apache/rocketmq/actions/runs/7649666926

With regards,
GitHub Actions via GitBox



[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" failed!

2024-01-24 Thread GitBox


The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has 
failed.
Run started by GitHub user dingshuangxi888 (triggered by dingshuangxi888).

Head commit for run:
c0012d40af35363a8913559898daea4c1b871193 / ShuangxiDing 

merge master

Report URL: https://github.com/apache/rocketmq/actions/runs/7649666927

With regards,
GitHub Actions via GitBox



[GH] (rocketmq-clients): Workflow run "CodeSpell Check" is working again!

2024-01-24 Thread GitBox


The GitHub Actions job "CodeSpell Check" on rocketmq-clients.git has succeeded.
Run started by GitHub user lizhanhui (triggered by lizhanhui).

Head commit for run:
47bd80cd7b9ab1eb6fcf93372c0f8c9f7a2c7178 / Li Zhanhui 
Use strong type in application code and primitive type for wire data only

Signed-off-by: Li Zhanhui 

Report URL: https://github.com/apache/rocketmq-clients/actions/runs/7650636463

With regards,
GitHub Actions via GitBox



[GH] (rocketmq-clients): Workflow run "License Checker" is working again!

2024-01-24 Thread GitBox


The GitHub Actions job "License Checker" on rocketmq-clients.git has succeeded.
Run started by GitHub user lizhanhui (triggered by lizhanhui).

Head commit for run:
47bd80cd7b9ab1eb6fcf93372c0f8c9f7a2c7178 / Li Zhanhui 
Use strong type in application code and primitive type for wire data only

Signed-off-by: Li Zhanhui 

Report URL: https://github.com/apache/rocketmq-clients/actions/runs/7650636458

With regards,
GitHub Actions via GitBox



Re: [PR] [rust]support message type check on rust client [rocketmq-clients]

2024-01-24 Thread via GitHub


glcrazier commented on PR #658:
URL: https://github.com/apache/rocketmq-clients/pull/658#issuecomment-1909430794

   @lizhanhui The new changes are way better. Thanks.


-- 
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] [rust]support message type check on rust client [rocketmq-clients]

2024-01-24 Thread via GitHub


lizhanhui merged PR #658:
URL: https://github.com/apache/rocketmq-clients/pull/658


-- 
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: [rust]support message type check on rust client (#658)

2024-01-24 Thread lizhanhui
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 65b70ed7 [rust]support message type check on rust client (#658)
65b70ed7 is described below

commit 65b70ed73259e8667e75a94e5162f75e91b4bf1b
Author: Qiping Luo 
AuthorDate: Thu Jan 25 14:51:24 2024 +0800

[rust]support message type check on rust client (#658)

* support message type check on rust client

* update test cases

* simplify MessageType conversion

* remove unused function

* fix code fmt issue

* fix cargo fmt issue

* Use strong type in application code and primitive type for wire data only

Signed-off-by: Li Zhanhui 

-

Signed-off-by: Li Zhanhui 
Co-authored-by: Li Zhanhui 
---
 rust/src/error.rs |  3 +++
 rust/src/model/message.rs | 29 +
 rust/src/producer.rs  | 46 +++---
 3 files changed, 63 insertions(+), 15 deletions(-)

diff --git a/rust/src/error.rs b/rust/src/error.rs
index 59d1eeb4..5210842e 100644
--- a/rust/src/error.rs
+++ b/rust/src/error.rs
@@ -33,6 +33,9 @@ pub enum ErrorKind {
 #[error("Message is invalid")]
 InvalidMessage,
 
+#[error("Message type not match with topic accept message type")]
+MessageTypeNotMatch,
+
 #[error("Server error")]
 Server,
 
diff --git a/rust/src/model/message.rs b/rust/src/model/message.rs
index 28c232e8..1defcd89 100644
--- a/rust/src/model/message.rs
+++ b/rust/src/model/message.rs
@@ -21,9 +21,18 @@ use std::collections::HashMap;
 
 use crate::error::{ClientError, ErrorKind};
 use crate::model::common::Endpoints;
+use crate::model::message::MessageType::{DELAY, FIFO, NORMAL, TRANSACTION};
 use crate::model::message_id::UNIQ_ID_GENERATOR;
 use crate::pb;
 
+#[derive(Clone, Copy, Debug)]
+pub enum MessageType {
+NORMAL = 1,
+FIFO = 2,
+DELAY = 3,
+TRANSACTION = 4,
+}
+
 /// [`Message`] is the data model for sending.
 pub trait Message {
 fn take_message_id(&mut self) -> String;
@@ -35,6 +44,17 @@ pub trait Message {
 fn take_message_group(&mut self) -> Option;
 fn take_delivery_timestamp(&mut self) -> Option;
 fn transaction_enabled(&mut self) -> bool;
+fn get_message_type(&self) -> MessageType;
+}
+
+pub trait MessageTypeAware {
+fn accept_type(&self, message_type: MessageType) -> bool;
+}
+
+impl MessageTypeAware for pb::MessageQueue {
+fn accept_type(&self, message_type: MessageType) -> bool {
+self.accept_message_types.contains(&(message_type as i32))
+}
 }
 
 pub(crate) struct MessageImpl {
@@ -47,6 +67,7 @@ pub(crate) struct MessageImpl {
 pub(crate) message_group: Option,
 pub(crate) delivery_timestamp: Option,
 pub(crate) transaction_enabled: bool,
+pub(crate) message_type: MessageType,
 }
 
 impl Message for MessageImpl {
@@ -85,6 +106,10 @@ impl Message for MessageImpl {
 fn transaction_enabled(&mut self) -> bool {
 self.transaction_enabled
 }
+
+fn get_message_type(&self) -> MessageType {
+self.message_type
+}
 }
 
 /// [`MessageBuilder`] is the builder for [`Message`].
@@ -108,6 +133,7 @@ impl MessageBuilder {
 message_group: None,
 delivery_timestamp: None,
 transaction_enabled: false,
+message_type: NORMAL,
 },
 }
 }
@@ -135,6 +161,7 @@ impl MessageBuilder {
 message_group: Some(message_group.into()),
 delivery_timestamp: None,
 transaction_enabled: false,
+message_type: FIFO,
 },
 }
 }
@@ -162,6 +189,7 @@ impl MessageBuilder {
 message_group: None,
 delivery_timestamp: Some(delay_time),
 transaction_enabled: false,
+message_type: DELAY,
 },
 }
 }
@@ -184,6 +212,7 @@ impl MessageBuilder {
 message_group: None,
 delivery_timestamp: None,
 transaction_enabled: true,
+message_type: TRANSACTION,
 },
 }
 }
diff --git a/rust/src/producer.rs b/rust/src/producer.rs
index 7e3f3996..2a69f079 100644
--- a/rust/src/producer.rs
+++ b/rust/src/producer.rs
@@ -26,9 +26,9 @@ use crate::client::Client;
 use crate::conf::{ClientOption, ProducerOption};
 use crate::error::{ClientError, ErrorKind};
 use crate::model::common::{ClientType, SendReceipt};
-use crate::model::message;
+use crate::model::message::{self, MessageTypeAware};
 use crate::model::transaction::{Transaction, TransactionChecker, 
TransactionImpl};
-use crate::pb::{Encoding, MessageType, Resource, SystemProperties};
+use crate::pb::{Encoding, Resource, SystemProperties};
 use crate::u

[GH] (rocketmq-clients): Workflow run "Node.js Coverage" is working again!

2024-01-24 Thread GitBox


The GitHub Actions job "Node.js Coverage" on rocketmq-clients.git has succeeded.
Run started by GitHub user lizhanhui (triggered by lizhanhui).

Head commit for run:
65b70ed73259e8667e75a94e5162f75e91b4bf1b / Qiping Luo 
[rust]support message type check on rust client (#658)

* support message type check on rust client

* update test cases

* simplify MessageType conversion

* remove unused function

* fix code fmt issue

* fix cargo fmt issue

* Use strong type in application code and primitive type for wire data only

Signed-off-by: Li Zhanhui 

-

Signed-off-by: Li Zhanhui 
Co-authored-by: Li Zhanhui 

Report URL: https://github.com/apache/rocketmq-clients/actions/runs/7650917480

With regards,
GitHub Actions via GitBox



Re: [I] [Bug] messages will permanently send to other broker when enable sendLatencyFault [rocketmq]

2024-01-24 Thread via GitHub


RongtongJin commented on issue #7779:
URL: https://github.com/apache/rocketmq/issues/7779#issuecomment-1909457243

   > > @Tcytw Good catch! Could you submit a pull reqeust to fix the issue?
   > 
   > @RongtongJin Of course. I have submitted the pull request at #7783
   
   
   It seems that @leizhiyuan had already submitted the same PR, and since he 
first proposed it, I will merge his PR into trunk.


-- 
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] [ISSUE #7713] MQFaultStrategy check queue if writable [rocketmq]

2024-01-24 Thread via GitHub


RongtongJin merged PR #7716:
URL: https://github.com/apache/rocketmq/pull/7716


-- 
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) branch 4.9.x updated: [ISSUE #7713] MQFaultStrategy check queue if writable

2024-01-24 Thread jinrongtong
This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch 4.9.x
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/4.9.x by this push:
 new 8d2c6613be [ISSUE #7713] MQFaultStrategy check queue if writable
8d2c6613be is described below

commit 8d2c6613be0500b1a9289a9d8db43d2d12642a74
Author: Lei Zhiyuan 
AuthorDate: Thu Jan 25 14:54:07 2024 +0800

[ISSUE #7713] MQFaultStrategy check queue if writable
---
 .../apache/rocketmq/client/impl/producer/TopicPublishInfo.java |  3 ++-
 .../org/apache/rocketmq/client/latency/MQFaultStrategy.java| 10 +++---
 2 files changed, 9 insertions(+), 4 deletions(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java
 
b/client/src/main/java/org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java
index 2f8337edef..22d4eb9234 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java
@@ -19,6 +19,7 @@ package org.apache.rocketmq.client.impl.producer;
 import java.util.ArrayList;
 import java.util.List;
 import org.apache.rocketmq.client.common.ThreadLocalIndex;
+import org.apache.rocketmq.common.constant.PermName;
 import org.apache.rocketmq.common.message.MessageQueue;
 import org.apache.rocketmq.common.protocol.route.QueueData;
 import org.apache.rocketmq.common.protocol.route.TopicRouteData;
@@ -95,7 +96,7 @@ public class TopicPublishInfo {
 public int getQueueIdByBroker(final String brokerName) {
 for (int i = 0; i < topicRouteData.getQueueDatas().size(); i++) {
 final QueueData queueData = 
this.topicRouteData.getQueueDatas().get(i);
-if (queueData.getBrokerName().equals(brokerName)) {
+if (PermName.isWriteable(queueData.getPerm()) && 
queueData.getBrokerName().equals(brokerName)) {
 return queueData.getWriteQueueNums();
 }
 }
diff --git 
a/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java 
b/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java
index ea3d07e6d0..b6915cda07 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java
@@ -73,10 +73,14 @@ public class MQFaultStrategy {
 if (writeQueueNums > 0) {
 final MessageQueue mq = tpInfo.selectOneMessageQueue();
 if (notBestBroker != null) {
-mq.setBrokerName(notBestBroker);
-
mq.setQueueId(tpInfo.getSendWhichQueue().incrementAndGet() % writeQueueNums);
+MessageQueue selectedMessageQueue = new MessageQueue();
+selectedMessageQueue.setTopic(mq.getTopic());
+selectedMessageQueue.setBrokerName(notBestBroker);
+
selectedMessageQueue.setQueueId(tpInfo.getSendWhichQueue().incrementAndGet() % 
writeQueueNums);
+return selectedMessageQueue;
+} else {
+return mq;
 }
-return mq;
 } else {
 latencyFaultTolerance.remove(notBestBroker);
 }



Re: [PR] fix the selectOneMessageQueue to avoid change messageQueue permanently [rocketmq]

2024-01-24 Thread via GitHub


RongtongJin merged PR #7783:
URL: https://github.com/apache/rocketmq/pull/7783


-- 
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) branch 4.9.x updated: [ISSUE #7779] Fix the selectOneMessageQueue to avoid change messageQueue permanently

2024-01-24 Thread jinrongtong
This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch 4.9.x
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/4.9.x by this push:
 new f9f5465819 [ISSUE #7779] Fix the selectOneMessageQueue to avoid change 
messageQueue permanently
f9f5465819 is described below

commit f9f5465819fdf8f6dca01cdb0af91ef2b3900cbb
Author: Tcytw <532260...@qq.com>
AuthorDate: Thu Jan 25 14:57:00 2024 +0800

[ISSUE #7779] Fix the selectOneMessageQueue to avoid change messageQueue 
permanently

Co-authored-by: tianyan 
---
 .../java/org/apache/rocketmq/client/latency/MQFaultStrategy.java| 6 +-
 1 file changed, 1 insertion(+), 5 deletions(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java 
b/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java
index b6915cda07..72e8c70389 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java
@@ -73,11 +73,7 @@ public class MQFaultStrategy {
 if (writeQueueNums > 0) {
 final MessageQueue mq = tpInfo.selectOneMessageQueue();
 if (notBestBroker != null) {
-MessageQueue selectedMessageQueue = new MessageQueue();
-selectedMessageQueue.setTopic(mq.getTopic());
-selectedMessageQueue.setBrokerName(notBestBroker);
-
selectedMessageQueue.setQueueId(tpInfo.getSendWhichQueue().incrementAndGet() % 
writeQueueNums);
-return selectedMessageQueue;
+return new MessageQueue(mq.getTopic(), notBestBroker, 
tpInfo.getSendWhichQueue().incrementAndGet() % writeQueueNums);
 } else {
 return mq;
 }



Re: [I] [Bug] messages will permanently send to other broker when enable sendLatencyFault [rocketmq]

2024-01-24 Thread via GitHub


RongtongJin closed issue #7779: [Bug] messages will permanently send to other 
broker when enable sendLatencyFault
URL: https://github.com/apache/rocketmq/issues/7779


-- 
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



svn commit: r66784 - in /release/rocketmq/rocketmq-clients/rocketmq-client-golang/5.1.0: ./ rocketmq-client-golang-v5.1.0-source-release.zip rocketmq-client-golang-v5.1.0-source-release.zip.asc rocket

2024-01-24 Thread jinrongtong
Author: jinrongtong
Date: Thu Jan 25 07:09:38 2024
New Revision: 66784

Log:
Release rocketmq grpc client go 5.1.0

Added:
release/rocketmq/rocketmq-clients/rocketmq-client-golang/5.1.0/

release/rocketmq/rocketmq-clients/rocketmq-client-golang/5.1.0/rocketmq-client-golang-v5.1.0-source-release.zip
   (with props)

release/rocketmq/rocketmq-clients/rocketmq-client-golang/5.1.0/rocketmq-client-golang-v5.1.0-source-release.zip.asc

release/rocketmq/rocketmq-clients/rocketmq-client-golang/5.1.0/rocketmq-client-golang-v5.1.0-source-release.zip.sha512

Added: 
release/rocketmq/rocketmq-clients/rocketmq-client-golang/5.1.0/rocketmq-client-golang-v5.1.0-source-release.zip
==
Binary file - no diff available.

Propchange: 
release/rocketmq/rocketmq-clients/rocketmq-client-golang/5.1.0/rocketmq-client-golang-v5.1.0-source-release.zip
--
svn:mime-type = application/octet-stream

Added: 
release/rocketmq/rocketmq-clients/rocketmq-client-golang/5.1.0/rocketmq-client-golang-v5.1.0-source-release.zip.asc
==
--- 
release/rocketmq/rocketmq-clients/rocketmq-client-golang/5.1.0/rocketmq-client-golang-v5.1.0-source-release.zip.asc
 (added)
+++ 
release/rocketmq/rocketmq-clients/rocketmq-client-golang/5.1.0/rocketmq-client-golang-v5.1.0-source-release.zip.asc
 Thu Jan 25 07:09:38 2024
@@ -0,0 +1,16 @@
+-BEGIN PGP SIGNATURE-
+
+iQIzBAABCAAdFiEE7J8mi0wgWQE4sR/nAUIOQpIpbq4FAmWmM6EACgkQAUIOQpIp
+bq5+TQ//Vy+2gIlOa4bWH2NCSHXqwIsqabNr0BS0PPPSZlmOvNwMmT72DSxcgC/q
+3Cr/oHwfWZTdRZcRqFr1u4lJVIyA4Kew72q0ys5uPrUhUYn1gI+qzoTj9MRg2S3K
+zWCzsu6OgaVTnQby68bDZ0aNPaKPgm7966+iizq5pPofeT6Loya5sYoT+LbMjhIe
+tqTqeWmRC9jFN02ErMeq/d0q52Be882Yd+qvV5klQ7bA384Gy6SLkhIiIzZr2TV0
+q+xcus3SzME+T0yiTBEcWX/ddCsdcsx8jW6oi9QntWJN/2xPJRd7NFdOZWsM/fs7
+h5BbbEY3SR59QwYaoDkY3y6StNNrhbnryVNua57+OYqiQEpQNdvujMOyVW8kw04+
+dSQ/2vwsO/5Pa1OyaYmRL5gV8S7Nj0SnIbo02VyyUW5yVkfmQ5Yt29LIIxPAwge1
+fqH9qVJnvZt+IrfAYNMQhcRKVnODeYE6mRNte0sbo3iuiS7OwvcNy8lgaG/HJs2r
+WY0OZGCdE7sfpqtzY/yAX8eJ3hkgjOBxCqE5a7XPgDTVdWVdWpW/AT3Q1oHsWuJD
+Cu+dquSe6S9dGl1kNIexT93x6aQXdQarl7jahVo9v8KGJnKzz9pgH/FbxLe8A2Fl
+Nyh+vG5VfuTd/LYW9o4Z6v3VtdN6bvQDQpJR1crbj6dOOqhzWcc=
+=jKzG
+-END PGP SIGNATURE-

Added: 
release/rocketmq/rocketmq-clients/rocketmq-client-golang/5.1.0/rocketmq-client-golang-v5.1.0-source-release.zip.sha512
==
--- 
release/rocketmq/rocketmq-clients/rocketmq-client-golang/5.1.0/rocketmq-client-golang-v5.1.0-source-release.zip.sha512
 (added)
+++ 
release/rocketmq/rocketmq-clients/rocketmq-client-golang/5.1.0/rocketmq-client-golang-v5.1.0-source-release.zip.sha512
 Thu Jan 25 07:09:38 2024
@@ -0,0 +1,3 @@
+rocketmq-clients/rocketmq-client-golang/5.1.0-rc1/rocketmq-client-golang-v5.1.0-rc1-source-release.zip:
 
+A3B1B74D 5BB998F2 2E5AFD28 F5EFB73E E69DDFA2 35FC5A10 B63F1650 AF893F67 
10D4EC91
+ 7AF4AC08 6E68CF7D 046625D0 A731B997 95E5B48A 33B823B2 BBF59434




[GH] (rocketmq): Workflow run "Build and Run Tests by Bazel" failed!

2024-01-24 Thread GitBox


The GitHub Actions job "Build and Run Tests by Bazel" on rocketmq.git has 
failed.
Run started by GitHub user dingshuangxi888 (triggered by dingshuangxi888).

Head commit for run:
933aa5aa6026cba55ab69d699005d21108a85f59 / ShuangxiDing 

部分字段不要序列化

Report URL: https://github.com/apache/rocketmq/actions/runs/7651167876

With regards,
GitHub Actions via GitBox



Re: [I] [Bug] messages will permanently send to other broker when enable sendLatencyFault [rocketmq]

2024-01-24 Thread via GitHub


Tcytw commented on issue #7779:
URL: https://github.com/apache/rocketmq/issues/7779#issuecomment-1909497804

   > > > @Tcytw Good catch! Could you submit a pull reqeust to fix the issue?
   > > 
   > > 
   > > @RongtongJin Of course. I have submitted the pull request at #7783
   > 
   > It seems that @leizhiyuan had already submitted the same PR, and since he 
first proposed it, I will merge his PR into trunk.
   
   okay


-- 
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 "E2E test for pull request" failed!

2024-01-24 Thread GitBox


The GitHub Actions job "E2E test for pull request" on rocketmq.git has failed.
Run started by GitHub user dingshuangxi888 (triggered by dingshuangxi888).

Head commit for run:
04eec3497895a1fa8a9c8fbe520406c62a05a5b0 / Zhouxiang Zhan 

Get namespace from header (#7782)

Report URL: https://github.com/apache/rocketmq/actions/runs/7651189596

With regards,
GitHub Actions via GitBox



[GH] (rocketmq): Workflow run "Coverage" failed!

2024-01-24 Thread GitBox


The GitHub Actions job "Coverage" on rocketmq.git has failed.
Run started by GitHub user dingshuangxi888 (triggered by dingshuangxi888).

Head commit for run:
933aa5aa6026cba55ab69d699005d21108a85f59 / ShuangxiDing 

部分字段不要序列化

Report URL: https://github.com/apache/rocketmq/actions/runs/7651167883

With regards,
GitHub Actions via GitBox



[PR] [ISSUE #615] Release RocketMQ gRPC Client Go SDK 5.1.0, update doc [rocketmq-site]

2024-01-24 Thread via GitHub


guyinyou opened a new pull request, #616:
URL: https://github.com/apache/rocketmq-site/pull/616

   Release RocketMQ gRPC Client Go SDK 5.1.0, update doc


-- 
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] Release RocketMQ gRPC Client Go SDK 5.1.0 [rocketmq-site]

2024-01-24 Thread via GitHub


guyinyou commented on issue #615:
URL: https://github.com/apache/rocketmq-site/issues/615#issuecomment-1909549716

   #616 


-- 
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] [ISSUE #615] Release RocketMQ gRPC Client Go SDK 5.1.0, update doc [rocketmq-site]

2024-01-24 Thread via GitHub


RongtongJin merged PR #616:
URL: https://github.com/apache/rocketmq-site/pull/616


-- 
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-site) branch new-official-website updated: [ISSUE #615] Release RocketMQ gRPC Client Go SDK 5.1.0, update doc

2024-01-24 Thread jinrongtong
This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch new-official-website
in repository https://gitbox.apache.org/repos/asf/rocketmq-site.git


The following commit(s) were added to refs/heads/new-official-website by this 
push:
 new 56c615a954 [ISSUE #615] Release RocketMQ gRPC Client Go SDK 5.1.0, 
update doc
56c615a954 is described below

commit 56c615a954a94a5b7a9c0d06944b4c8672902003
Author: guyinyou <36399867+guyin...@users.noreply.github.com>
AuthorDate: Thu Jan 25 15:53:36 2024 +0800

[ISSUE #615] Release RocketMQ gRPC Client Go SDK 5.1.0, update doc

Co-authored-by: guyinyou 
---
 src/pages/download.md | 7 ---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/src/pages/download.md b/src/pages/download.md
index d8825f2be5..4a90c53189 100644
--- a/src/pages/download.md
+++ b/src/pages/download.md
@@ -61,9 +61,10 @@
 
 ## RocketMQ gRPC Client Go SDK
 
-| 版本  | 文档 | 发布日期  
 | Source 下载   | End of Support 
|
-| - |  | 
-- |  | 
-- |
-| **5.0.0** | [Release 
Notes](https://github.com/apache/rocketmq-clients/releases/tag/rocketmq-client-golang-5.0.0)
 | 2022.9.22  | 
[download.zip](https://github.com/apache/rocketmq-clients/archive/refs/tags/rocketmq-client-golang-5.0.0.zip)
 |  |
+| 版本| 文档   
 | 发布日期  | Source 下载

 | End of Support |
+|---|---|---|---|
 -- |
+| **5.0.0** | [Release 
Notes](https://github.com/apache/rocketmq-clients/releases/tag/rocketmq-client-golang-5.0.0)
 | 2022.9.22 | 
[download.zip](https://github.com/apache/rocketmq-clients/archive/refs/tags/rocketmq-client-golang-5.0.0.zip)
 |  |
+| **5.1.0** | [Release 
Notes](https://github.com/apache/rocketmq-clients/releases/tag/golang%2Fv5.1.0-rc.1)
 | 2024.1.25 | 
[download.zip](https://github.com/apache/rocketmq-clients/archive/refs/tags/golang/v5.1.0-rc.1.zip)
   |  |
 
 ---
 



Re: [I] Release RocketMQ gRPC Client Go SDK 5.1.0 [rocketmq-site]

2024-01-24 Thread via GitHub


RongtongJin closed issue #615: Release RocketMQ gRPC Client Go SDK 5.1.0
URL: https://github.com/apache/rocketmq-site/issues/615


-- 
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