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 7854fcb7d..e1e4c2587 100644
---
a/client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java
+++
b/cli
diff --git a/.travis.yml b/.travis.yml
index 3ced58e..c7d31e0 100644
--- a/.travis.yml
+++ b/.travis.yml
@@ -1,6 +1,8 @@
language: node_js
node_js: 10
+env:
+
NODE_ROCKETMQ_REGISTRY=https://opensource-rocketmq-client-us.oss-us-west-1.aliyuncs.com/
before_script:
- wget
http://us.mirror
diff --git a/.gitignore b/.gitignore
index c9d16aa..1a90945 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,6 +1,10 @@
# Created by https://www.gitignore.io/api/c++,node,linux,macos,windows
# Edit at https://www.gitignore.io/?templates=c++,node,linux,macos,windows
+### IDE ###
+.idea
+idea/*
+
diff --git a/.eslintrc b/.eslintrc
deleted file mode 100644
index 4601220..000
--- a/.eslintrc
+++ /dev/null
@@ -1,5 +0,0 @@
-{
-"extends": [
- "rocketmq-style"
-]
-}
diff --git a/.eslintrc.js b/.eslintrc.js
new file mode 100644
index 000..dc18852
--- /dev/null
+++ b/.eslintrc.
diff --git a/src/transport/TcpTransport.cpp b/src/transport/TcpTransport.cpp
index 011c4202..2c148e7c 100644
--- a/src/transport/TcpTransport.cpp
+++ b/src/transport/TcpTransport.cpp
@@ -35,7 +35,7 @@ TcpTransport::TcpTransport(TcpRemotingClient
*pTcpRemointClient,
m_event_base_cv(),
diff --git a/src/consumer/PullRequest.cpp b/src/consumer/PullRequest.cpp
index 8510e430..b261d82d 100644
--- a/src/consumer/PullRequest.cpp
+++ b/src/consumer/PullRequest.cpp
@@ -28,8 +28,8 @@ PullRequest::PullRequest(const string& groupname)
m_queueOffsetMax(0),
m_bDroped(false),
diff --git a/package.json b/package.json
index ae0df92..074198d 100644
--- a/package.json
+++ b/package.json
@@ -1,6 +1,6 @@
{
"name": "apache-rocketmq",
- "version": "0.0.1-dev",
+ "version": "1.0.0-rc1",
"cppSDKVersion": "1.2.0",
"description": "RocketMQ binding for Node.js",
"main
diff --git a/example/CAsyncProducer.c b/example/CAsyncProducer.c
new file mode 100644
index ..56496b5a
--- /dev/null
+++ b/example/CAsyncProducer.c
@@ -0,0 +1,95 @@
+/*
+* Licensed to the Apache Software Foundation (ASF) under one or more
+* contributor license agreements. See the NOTICE f
diff --git a/distribution/conf/flowControl.yml
b/distribution/conf/flowControl.yml
new file mode 100644
index 0..cf71d2ddc
--- /dev/null
+++ b/distribution/conf/flowControl.yml
@@ -0,0 +1,19 @@
+snode:
+ countLimit: # flow control type, only requestCount & requestSize support
+- flow
Oliverwqcwrw opened a new issue, #343:
URL: https://github.com/apache/rocketmq-site/issues/343
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/).
**
Oliverwqcwrw opened a new pull request, #344:
URL: https://github.com/apache/rocketmq-site/pull/344
Please do not create a Pull Request without creating an issue first.
## What is the purpose of the change
Close #343
## Brief changelog
XX
## Verifying this
caigy commented on issue #131:
URL:
https://github.com/apache/rocketmq-operator/issues/131#issuecomment-1281746695
@Slideee In current implementation, the complexity will increase as the
number of broker clusters increases, because name service controller should
update the `namesrvAddr` of
caigy opened a new issue, #135:
URL: https://github.com/apache/rocketmq-operator/issues/135
In RocketMQ 5.0, a new cluster mode enabling auto-switching broker roles is
provided
(https://rocketmq.apache.org/docs/deploymentOperations/16autoswitchdeploy).
RocketMQ Operator should support it.
tsunghanjacktsai opened a new issue, #345:
URL: https://github.com/apache/rocketmq-site/issues/345
Some download links in the download page are not able to download the
released files directly, but can only jump to the Apache official website. It
is expected to start downloading the file it
RongtongJin opened a new pull request, #346:
URL: https://github.com/apache/rocketmq-site/pull/346
Please do not create a Pull Request without creating an issue first.
## What is the purpose of the change
Fix some releases download url invalid
## Brief changelog
F
RongtongJin opened a new issue, #347:
URL: https://github.com/apache/rocketmq-site/issues/347
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/).
**B
caigy commented on code in PR #134:
URL: https://github.com/apache/rocketmq-operator/pull/134#discussion_r997677475
##
deploy/crds/rocketmq.apache.org_proxys.yaml:
##
@@ -0,0 +1,7899 @@
+
Review Comment:
Pls add license header.
##
pkg/apis/rocketmq/v1alpha1/proxy_
odbozhou merged PR #346:
URL: https://github.com/apache/rocketmq-site/pull/346
--
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...@rocke
caigy commented on issue #130:
URL:
https://github.com/apache/rocketmq-operator/issues/130#issuecomment-1281811829
> > @koalawangyang Please try running `go mod tidy`. BTW, would you like to
optimize the building part of README after the problem is resolved?
>
> Hi caigy, Thanks for
ist (#5341)
Report URL: https://github.com/apache/rocketmq/actions/runs/3270710848
With regards,
GitHub Actions via GitBox
MumfordSons commented on issue #5342:
URL: https://github.com/apache/rocketmq/issues/5342#issuecomment-1281840372
> @MumfordSons Thanks for your feedback! Actually message body in
`messageView` is readonly, which means you could not get `byte[]` from
`bytebuffer` directly because `byte[]` h
MumfordSons closed issue #5342: how to get message's body from messgeView
URL: https://github.com/apache/rocketmq/issues/5342
--
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
ShannonDing merged PR #5340:
URL: https://github.com/apache/rocketmq/pull/5340
--
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...@rocke
ShannonDing closed issue #5339: Fix BrokerContainer document error
URL: https://github.com/apache/rocketmq/issues/5339
--
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 unsubs
com/apache/rocketmq/actions/runs/3270883986
With regards,
GitHub Actions via GitBox
MumfordSons opened a new issue, #262:
URL: https://github.com/apache/rocketmq-clients/issues/262
now messageView.getBody() returns a ByteBuffer object and can't directly
get body byte array from ByteBuffer
.
Although it is still difficult to set
overstep123 closed pull request #83: add pod anti affinity for broker
URL: https://github.com/apache/rocketmq-operator/pull/83
--
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.
T
mq-clients/actions/runs/3271455298
With regards,
GitHub Actions via GitBox
lollipopjin opened a new pull request, #5343:
URL: https://github.com/apache/rocketmq/pull/5343
**Make sure set the target branch to `develop`**
## What is the purpose of the change
Parse DLQ information as message's system properties.
## Brief changelog
Upgrade r
URL: https://github.com/apache/rocketmq/actions/runs/3271532586
With regards,
GitHub Actions via GitBox
e/rocketmq-clients/actions/runs/3271455298
With regards,
GitHub Actions via GitBox
nformation.
Report URL: https://github.com/apache/rocketmq/actions/runs/3271532595
With regards,
GitHub Actions via GitBox
aaron-ai merged PR #263:
URL: https://github.com/apache/rocketmq-clients/pull/263
--
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...@ro
nformation.
Report URL: https://github.com/apache/rocketmq/actions/runs/3271532591
With regards,
GitHub Actions via GitBox
BiggerBrain commented on issue #5331:
URL: https://github.com/apache/rocketmq/issues/5331#issuecomment-1282017105
> I also believe that the quality of rocketmq unit testing needs to be
improved, and I would love to be a part of that effort
--
This is an automated message from the
nformation.
Report URL: https://github.com/apache/rocketmq/actions/runs/3271532595
With regards,
GitHub Actions via GitBox
Report URL: https://github.com/apache/rocketmq/actions/runs/3271865835
With regards,
GitHub Actions via GitBox
github.com/apache/rocketmq/actions/runs/3271865841
With regards,
GitHub Actions via GitBox
3271983702
With regards,
GitHub Actions via GitBox
URL: https://github.com/apache/rocketmq/actions/runs/3271865837
With regards,
GitHub Actions via GitBox
aaron-ai merged PR #5343:
URL: https://github.com/apache/rocketmq/pull/5343
--
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
e/rocketmq/actions/runs/3271983689
With regards,
GitHub Actions via GitBox
lizhanhui merged PR #5336:
URL: https://github.com/apache/rocketmq/pull/5336
--
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...@rocketm
lizhanhui closed issue #5332: Remove DefaultMessageStore's private field
printTimes that is never used
URL: https://github.com/apache/rocketmq/issues/5332
--
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 g
rade proto version to 2.0.1, and adapt to parse dlq information.
* Upgrade proto version to 2.0.1 in bazel config.
Report URL: https://github.com/apache/rocketmq/actions/runs/3272145409
With regards,
GitHub Actions via GitBox
ntTimes that is
never used (#5336)
* [ISSUE #5332]Remove DefaultMessageStore's private field printTimes that is
never used
* Remove unused imports
Co-authored-by: Zhanhui Li
Report URL: https://github.com/apache/rocketmq/actions/runs/3272298326
With regards,
GitHub Actions via GitBox
on. (#5343)
* Upgrade proto version to 2.0.1, and adapt to parse dlq information.
* Upgrade proto version to 2.0.1 in bazel config.
Report URL: https://github.com/apache/rocketmq/actions/runs/3272145406
With regards,
GitHub Actions via GitBox
ver used (#5336)
* [ISSUE #5332]Remove DefaultMessageStore's private field printTimes that is
never used
* Remove unused imports
Co-authored-by: Zhanhui Li
Report URL: https://github.com/apache/rocketmq/actions/runs/3272298341
With regards,
GitHub Actions via GitBox
ntTimes that is
never used (#5336)
* [ISSUE #5332]Remove DefaultMessageStore's private field printTimes that is
never used
* Remove unused imports
Co-authored-by: Zhanhui Li
Report URL: https://github.com/apache/rocketmq/actions/runs/3272298329
With regards,
GitHub Actions via GitBox
lizhanhui opened a new issue, #5344:
URL: https://github.com/apache/rocketmq/issues/5344
The store module assumes Linux as OS. This results in test case failure for
the Windows CI pipeline.
Introduce Junit5 and disable test cases that do not work on Windows using
https://junit.org/ju
lizhanhui opened a new pull request, #5345:
URL: https://github.com/apache/rocketmq/pull/5345
**Make sure set the target branch to `develop`**
## What is the purpose of the change
Fix https://github.com/apache/rocketmq/issues/5344
## Brief changelog
XX
## Ve
tions/runs/3272885627
With regards,
GitHub Actions via GitBox
mq/actions/runs/3272932508
With regards,
GitHub Actions via GitBox
mq/actions/runs/3272952307
With regards,
GitHub Actions via GitBox
codecov-commenter commented on PR #5345:
URL: https://github.com/apache/rocketmq/pull/5345#issuecomment-1282249318
#
[Codecov](https://codecov.io/gh/apache/rocketmq/pull/5345?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+S
tions/runs/3272885629
With regards,
GitHub Actions via GitBox
mq/actions/runs/3272932513
With regards,
GitHub Actions via GitBox
e
Report URL: https://github.com/apache/rocketmq/actions/runs/3270267414
With regards,
GitHub Actions via GitBox
e
Report URL: https://github.com/apache/rocketmq/actions/runs/3270267417
With regards,
GitHub Actions via GitBox
mq/actions/runs/3272952292
With regards,
GitHub Actions via GitBox
://github.com/apache/rocketmq/actions/runs/3270267419
With regards,
GitHub Actions via GitBox
mxsm opened a new pull request, #5346:
URL: https://github.com/apache/rocketmq/pull/5346
**Make sure set the target branch to `develop`**
## What is the purpose of the change
X
## Brief changelog
XX
## Verifying this change
Follow this
mxsm closed pull request #5346: Bbb
URL: https://github.com/apache/rocketmq/pull/5346
--
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..
ctions via GitBox
0156
With regards,
GitHub Actions via GitBox
mxsm commented on PR #5325:
URL: https://github.com/apache/rocketmq/pull/5325#issuecomment-1282553176
Hi @lizhanhui I have sloved failed test case, PTAL~
--
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 t
github.com/apache/rocketmq/actions/runs/3274425507
With regards,
GitHub Actions via GitBox
travisdowns opened a new issue, #5347:
URL: https://github.com/apache/rocketmq/issues/5347
rocketmq-tools depends on logback-classic, which includes a
`StaticLoggerBinder` class which binds slf4j to logback.
This binding shouldn't be made by a library since only one binding can exist
j2gg0s closed issue #941: PushConsumer's default config easy to casue recreate
`processQueue`
URL: https://github.com/apache/rocketmq-client-go/issues/941
--
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 g
lizhimins closed issue #5292: [RIP-48] Support reset offset in server side to
improve the success rate
URL: https://github.com/apache/rocketmq/issues/5292
--
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 g
lizhimins opened a new issue, #5348:
URL: https://github.com/apache/rocketmq/issues/5348
doc:
https://github.com/apache/rocketmq/wiki/RIP-48-Enhance-server-side-offset-management-ability
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on
mq/actions/runs/3278221610
With regards,
GitHub Actions via GitBox
github.com/apache/rocketmq/actions/runs/3278221617
With regards,
GitHub Actions via GitBox
github.com/apache/rocketmq/actions/runs/3278221621
With regards,
GitHub Actions via GitBox
lizhimins commented on issue #5348:
URL: https://github.com/apache/rocketmq/issues/5348#issuecomment-1283275259
Can you help review this pull request? @xdkxlk
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL ab
tions/runs/3278243916
With regards,
GitHub Actions via GitBox
th regards,
GitHub Actions via GitBox
tions/runs/3278243917
With regards,
GitHub Actions via GitBox
2011shenlin commented on code in PR #36:
URL:
https://github.com/apache/rocketmq-eventbridge/pull/36#discussion_r998873415
##
domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/apidestination/ApiDestinationService.java:
##
@@ -57,7 +58,11 @@ public String createA
e/rocketmq/actions/runs/3278348272
With regards,
GitHub Actions via GitBox
caigy commented on issue #5347:
URL: https://github.com/apache/rocketmq/issues/5347#issuecomment-1283319777
rocketmq-tool is also a 'final' application, used in `mqadmin` command. It
might be the reason why logback-classic was imported.
--
This is an automated message from the Apache Git
Oliverwqcwrw opened a new pull request, #348:
URL: https://github.com/apache/rocketmq-site/pull/348
Please do not create a Pull Request without creating an issue first.
## What is the purpose of the change
Follow #343
## Brief changelog
XX
## Verifying thi
3278348271
With regards,
GitHub Actions via GitBox
codecov-commenter commented on PR #5349:
URL: https://github.com/apache/rocketmq/pull/5349#issuecomment-1283331597
#
[Codecov](https://codecov.io/gh/apache/rocketmq/pull/5349?src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&utm_term=The+Apache+S
e/rocketmq/actions/runs/3278348291
With regards,
GitHub Actions via GitBox
1 - 100 of 24623 matches
Mail list logo
