[I] producer send msg timeout option does not take effect [rocketmq-client-go]
twz915 opened a new issue, #1110: URL: https://github.com/apache/rocketmq-client-go/issues/1110 The issue tracker is **ONLY** used for the go client (feature request of RocketMQ need to follow [RIP process](https://github.com/apache/rocketmq/wiki/RocketMQ-Improvement-Proposal)). Keep in mind, please check whether there is an existing same report before your raise a new one. Alternately (especially if your communication is not a bug report), you can send mail to our [mailing lists](http://rocketmq.apache.org/about/contact/). We welcome any friendly suggestions, bug fixes, collaboration, and other improvements. Please ensure that your bug report is clear and that it is complete. Otherwise, we may be unable to understand it or to reproduce it, either of which would prevent us from fixing the bug. We strongly recommend the report(bug report or feature request) could include some hints as to the following: **BUG REPORT** 1. Please describe the issue you observed: ## What is the purpose of the change producer send msg timeout option does not take effect ``` rocketmq.NewProducer( producer.WithSendMsgTimeout(time.Second*3), producer.WithRetry(2), ) ``` In most cases, a fixed timeout of 3 seconds is written into the code, preventing the configuration from taking effect. -- 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
Re: [I] The RocketMQ Connect quick start and practical documentation contains multiple errors, hard to experience it step by step [rocketmq-site]
patrickYang6625 commented on issue #608: URL: https://github.com/apache/rocketmq-site/issues/608#issuecomment-1827105610 Docs updated, close 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] The RocketMQ Connect quick start and practical documentation contains multiple errors, hard to experience it step by step [rocketmq-site]
patrickYang6625 closed issue #608: The RocketMQ Connect quick start and practical documentation contains multiple errors, hard to experience it step by step URL: https://github.com/apache/rocketmq-site/issues/608 -- 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 #217]Compatible with dynamic IP [rocketmq-mqtt]
lzkisok closed pull request #223: [ISSUE #217]Compatible with dynamic IP URL: https://github.com/apache/rocketmq-mqtt/pull/223 -- 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 #217]Compatible with dynamic IP [rocketmq-mqtt]
lzkisok commented on PR #223: URL: https://github.com/apache/rocketmq-mqtt/pull/223#issuecomment-1827081945 @pingww 提交到develop -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] fix #217 [rocketmq-mqtt]
lzkisok closed pull request #220: fix #217 URL: https://github.com/apache/rocketmq-mqtt/pull/220 -- 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] [ISSUE #217]Compatible with dynamic IP [rocketmq-mqtt]
lzkisok opened a new pull request, #223: URL: https://github.com/apache/rocketmq-mqtt/pull/223 fix #217 -- 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: fix producer send msg timeout option does not take effect [rocketmq-client-go]
twz915 opened a new pull request, #1109: URL: https://github.com/apache/rocketmq-client-go/pull/1109 ## What is the purpose of the change fix producer send msg timeout option does not take effect -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GH] (rocketmq): Workflow run "Build and Run Tests by Maven" failed!
The GitHub Actions job "Build and Run Tests by Maven" on rocketmq.git has failed. Run started by GitHub user keranbingaa (triggered by keranbingaa). Head commit for run: e9a52ac43cb12af8a4c8166fb95814d02fcf467d / keranbingaa <397294...@qq.com> fix ISSUE #7534 Report URL: https://github.com/apache/rocketmq/actions/runs/6999704237 With regards, GitHub Actions via GitBox
[I] commit transaction message,But it keeps triggering a backcheck [rocketmq-spring]
anxinyh opened a new issue, #598: URL: https://github.com/apache/rocketmq-spring/issues/598 rocketmq version:5.1.4 starter version:2.2.3 executeLocalTransaction will always trigger checkLocalTransaction, whether it returns a COMMIT or UNKNOWN This situation is up and down, and no rule has been found for the time being. May I ask what is going on?  -- 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
Re: [I] Lots of deprecated classes and methods are used in example module with tons of check style error [rocketmq]
zhouxinyu commented on issue #3397: URL: https://github.com/apache/rocketmq/issues/3397#issuecomment-1827034631 @yp969803 Assigned, thanks for your interest in 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 For queries about this service, please contact Infrastructure at: us...@infra.apache.org
[GH] (rocketmq-clients): Workflow run "Node.js Coverage" failed!
The GitHub Actions job "Node.js Coverage" on rocketmq-clients.git has failed. Run started by GitHub user lizhanhui (triggered by lizhanhui). Head commit for run: e2c0b97aed7aa17b6c9cef8fd86f1d70faa2ba19 / ainokiseki <43086824+ainokis...@users.noreply.github.com> Golang: fix goroutine leak issue (#613) * fix goroutine leak * test version * Revert "test version" This reverts commit 23da93ce6e7d01ab15884edbb2b8a80a5e7e46a9. * fix: correct spell errors Signed-off-by: Li Zhanhui - Signed-off-by: Li Zhanhui Co-authored-by: bo.jiang03 Co-authored-by: Li Zhanhui Report URL: https://github.com/apache/rocketmq-clients/actions/runs/6999812100 With regards, GitHub Actions via GitBox
(rocketmq-clients) branch master updated: Golang: fix goroutine leak issue (#613)
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 e2c0b97a Golang: fix goroutine leak issue (#613)
e2c0b97a is described below
commit e2c0b97aed7aa17b6c9cef8fd86f1d70faa2ba19
Author: ainokiseki <43086824+ainokis...@users.noreply.github.com>
AuthorDate: Mon Nov 27 10:21:23 2023 +0800
Golang: fix goroutine leak issue (#613)
* fix goroutine leak
* test version
* Revert "test version"
This reverts commit 23da93ce6e7d01ab15884edbb2b8a80a5e7e46a9.
* fix: correct spell errors
Signed-off-by: Li Zhanhui
-
Signed-off-by: Li Zhanhui
Co-authored-by: bo.jiang03
Co-authored-by: Li Zhanhui
---
golang/client.go | 5 +
1 file changed, 5 insertions(+)
diff --git a/golang/client.go b/golang/client.go
index 0a7defaa..45e4b549 100644
--- a/golang/client.go
+++ b/golang/client.go
@@ -102,6 +102,11 @@ func (cs *defaultClientSession) startUp() {
cs.cli.log.Infof("defaultClientSession is startUp! endpoints=%v",
cs.endpoints)
go func() {
for {
+ select {
+ case <-cs.cli.done:
+ return
+ default:
+ }
// ensure that observer is present, if not wait for it
to be regenerated on publish.
observer, acquired_observer := cs._acquire_observer()
if !acquired_observer {
Re: [PR] Golang: fix goroutine leak issue [rocketmq-clients]
lizhanhui merged PR #613: URL: https://github.com/apache/rocketmq-clients/pull/613 -- 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 "Coverage" failed!
The GitHub Actions job "Coverage" on rocketmq.git has failed. Run started by GitHub user keranbingaa (triggered by keranbingaa). Head commit for run: e9a52ac43cb12af8a4c8166fb95814d02fcf467d / keranbingaa <397294...@qq.com> fix ISSUE #7534 Report URL: https://github.com/apache/rocketmq/actions/runs/6999704226 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 keranbingaa (triggered by keranbingaa). Head commit for run: e9a52ac43cb12af8a4c8166fb95814d02fcf467d / keranbingaa <397294...@qq.com> fix ISSUE #7534 Report URL: https://github.com/apache/rocketmq/actions/runs/6999704231 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 keranbingaa (triggered by keranbingaa). Head commit for run: e9a52ac43cb12af8a4c8166fb95814d02fcf467d / keranbingaa <397294...@qq.com> fix ISSUE #7534 Report URL: https://github.com/apache/rocketmq/actions/runs/6999704230 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 keranbingaa (triggered by keranbingaa). Head commit for run: e955e4399ceed5b5a1fbadc400883cfc5f99e726 / AYue <40812847+ayue...@users.noreply.github.com> [ISSUE #7577] SlaveActingMaster Timer Message retry without escape logic (#7578) Co-authored-by: ayue Report URL: https://github.com/apache/rocketmq/actions/runs/6999715430 With regards, GitHub Actions via GitBox
[PR] [ISSUE #7534] use high performance concurrent set to replace copyonwriteset [rocketmq]
keranbingaa opened a new pull request, #7583: URL: https://github.com/apache/rocketmq/pull/7583 ### Which Issue(s) This PR Fixes Fixes #issue_id ### Brief Description ### How Did You Test This Change? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [PR] [ISSUE #7534]use a new class to replace topiclist in concurrent scene [rocketmq]
keranbingaa closed pull request #7559: [ISSUE #7534]use a new class to replace topiclist in concurrent scene URL: https://github.com/apache/rocketmq/pull/7559 -- 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] Golang: fix goroutine leak issue [rocketmq-clients]
github-actions[bot] commented on PR #613: URL: https://github.com/apache/rocketmq-clients/pull/613#issuecomment-1826954773 This PR is stale because it has been open for 30 days with no activity. It will be closed in 3 days if no further activity occurs. If you wish not to mark it as stale, please leave a comment in this 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
Re: [PR] add switch enableTransCheckMaxTimeTopic [rocketmq]
github-actions[bot] closed pull request #5581: add switch enableTransCheckMaxTimeTopic URL: https://github.com/apache/rocketmq/pull/5581 -- 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] add switch enableTransCheckMaxTimeTopic [rocketmq]
github-actions[bot] commented on PR #5581: URL: https://github.com/apache/rocketmq/pull/5581#issuecomment-1826949710 This PR was closed because it has been inactive for 3 days since being marked as stale. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
Re: [I] [Enhancement] checkGroup repeated verification [rocketmq]
liushangqing9803 closed issue #7336: [Enhancement] checkGroup repeated verification URL: https://github.com/apache/rocketmq/issues/7336 -- 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 #7336] Validators.checkGroup method verified that the group name is null,so … [rocketmq]
liushangqing9803 closed pull request #7327: [ISSUE #7336] Validators.checkGroup method verified that the group name is null,so … URL: https://github.com/apache/rocketmq/pull/7327 -- 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-eventbridge) 32/33: [e2eTest] add license header
This is an automated email from the ASF dual-hosted git repository. shenlin pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git commit 6be3034fc6f278e791ad442b45cd7d665d2339bd Author: wangkai AuthorDate: Tue Nov 21 18:13:38 2023 +0800 [e2eTest] add license header --- test/rocketmq-eventbridge-e2etest/pom.xml| 15 --- .../apache/rocketmq/eventbridge/e2etest/BaseTest.java| 16 .../e2etest/controller/ApplicationTagControllerTest.java | 16 .../apache/rocketmq/eventbridge/e2etest/util/Utils.java | 16 4 files changed, 60 insertions(+), 3 deletions(-) diff --git a/test/rocketmq-eventbridge-e2etest/pom.xml b/test/rocketmq-eventbridge-e2etest/pom.xml index e5abdb9..89ee8b6 100644 --- a/test/rocketmq-eventbridge-e2etest/pom.xml +++ b/test/rocketmq-eventbridge-e2etest/pom.xml @@ -1,6 +1,15 @@ - -http://maven.apache.org/POM/4.0.0"; - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; + + +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";> rocketmq-eventbridge-test diff --git a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/BaseTest.java b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/BaseTest.java index 5e6248e..ad0e8df 100644 --- a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/BaseTest.java +++ b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/BaseTest.java @@ -1,3 +1,19 @@ +/* + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + */ package org.apache.rocketmq.eventbridge.e2etest; import com.fasterxml.jackson.core.JsonParseException; diff --git a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java index f97ab83..cf6570f 100644 --- a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java +++ b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java @@ -1,3 +1,19 @@ +/* + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. + */ package org.apache.rocketmq.eventbridge.e2etest.controller; import lombok.extern.slf4j.Slf4j; diff --git a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/util/Utils.java b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/util/Utils.java index 6627ffe..671c0d1 100644 --- a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/util/Utils.java +++ b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/util/Utils.java @@ -1,3 +1,19 @@ +/* + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (th
(rocketmq-eventbridge) 20/33: [e2eTest] add e2eTest model
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit a0f5bcef2c9341c5266c92fbb68361bf67e5e195
Author: wangkai
AuthorDate: Mon Oct 23 21:26:14 2023 +0800
[e2eTest] add e2eTest model
---
.../eventbridge/e2etest/controller/ApplicationTagControllerTest.java| 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
index 7998783..3a6e284 100644
---
a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
+++
b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
@@ -46,12 +46,12 @@ public class ApplicationTagControllerTest extends BaseTest {
while( retries < 10 ) {
data = FileUtils.readFileToString(file, "UTF-8");
if (StringUtils.isNotBlank(data)) {
-Assert.assertEquals("A test recrod.\n", data);
break;
}
Thread.sleep(5);
retries++;
}
+Assert.assertEquals("A test recrod.\n", data);
}
(rocketmq-eventbridge) 28/33: [e2eTest] add e2eTest model
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit 08b9d087cbb454bb11c534ab33073069115c12bf
Author: wangkai
AuthorDate: Fri Nov 3 16:59:53 2023 +0800
[e2eTest] add e2eTest model
---
.../adapter/storage/rocketmq/impl/DefaultSendCallback.java| 4
.../adapter/storage/rocketmq/impl/RocketMQEventDataRepository.java| 3 +++
2 files changed, 7 insertions(+)
diff --git
a/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/DefaultSendCallback.java
b/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/DefaultSendCallback.java
index 35bc7ef..d1df650 100644
---
a/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/DefaultSendCallback.java
+++
b/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/DefaultSendCallback.java
@@ -17,12 +17,14 @@
package org.apache.rocketmq.eventbridge.adapter.storage.rocketmq.impl;
+import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.client.producer.SendCallback;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.eventbridge.domain.model.data.PutEventCallback;
import
org.apache.rocketmq.eventbridge.domain.model.data.PutEventsResponseEntry;
import org.apache.rocketmq.eventbridge.exception.code.DefaultErrorCode;
+@Slf4j
public class DefaultSendCallback implements SendCallback {
PutEventCallback putEventCallback;
@@ -35,6 +37,7 @@ public class DefaultSendCallback implements SendCallback {
@Override
public void onSuccess(SendResult sendResult) {
+log.info("send msg to topic :{} success result.", sendResult);
entry.setEventId(sendResult.getMsgId());
entry.setErrorCode(DefaultErrorCode.Success.getCode());
putEventCallback.endProcess(entry);
@@ -42,6 +45,7 @@ public class DefaultSendCallback implements SendCallback {
@Override
public void onException(Throwable throwable) {
+log.error("send msg to topic : fail result.", throwable);
entry.setErrorCode(DefaultErrorCode.InternalError.getCode());
entry.setErrorMessage(throwable.getMessage());
putEventCallback.endProcess(entry);
diff --git
a/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/RocketMQEventDataRepository.java
b/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/RocketMQEventDataRepository.java
index 5b1d796..bf24411 100644
---
a/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/RocketMQEventDataRepository.java
+++
b/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/RocketMQEventDataRepository.java
@@ -75,8 +75,11 @@ public class RocketMQEventDataRepository implements
EventDataRepository {
String topicName = this.getTopicName(accountId, eventBusName);
Message msg = eventDataOnRocketMQConnectAPI.converter(accountId,
topicName, eventBridgeEvent);
try {
+log.info("send msg to topic :{} before.", topicName);
producer.send(msg, new DefaultSendCallback(putEventCallback),
1000L);
+log.info("send msg to topic :{} end.", topicName);
} catch (Throwable e) {
+log.info("send msg to topic :{} failed. and exception is {}",
topicName, e.toString());
throw new EventBridgeException(EventBridgeErrorCode.InternalError,
e);
}
return true;
(rocketmq-eventbridge) branch main updated (e67f3da -> 9ecd538)
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
from e67f3da Rename RocketMQEventBridgeRuntimeArchitectDesign to
RocketMQEventBridgeRuntimeArchitectDesign.md
new 1ff638e Set up CI with Azure Pipelines
new ab2b6e1 1.modify maven publish
new 2b1cee9 1.modify maven publish
new bffd1fb 1.modify maven publish
new fab20bc 1.modify workflows file
new bc0e8bb 1.modify workflows mvn file
new 11e4ec3 1.modify workflows mvn file
new 0253e9f 1.移除文件
new 8d9fd69 1.修改mvn publish文件
new 42f79ea 1.修改mvn publish文件
new 7ac61ee 1.修改docker run命令
new a82229c 1.修改docker run命令
new faa1e15 1.修改docker run命令
new 5426245 [e2eTest] add e2eTest model
new 8696a41 [e2eTest] add e2eTest model
new 101056a [e2eTest] add e2eTest model
new 41bfec2 [e2eTest] add e2eTest model
new bf89b28 [e2eTest] add e2eTest model
new 668886e [e2eTest] add e2eTest model
new a0f5bce [e2eTest] add e2eTest model
new 93f643e [e2eTest] add e2eTest model
new 8ad96c8 [e2eTest] add e2eTest model
new 149b011 [e2eTest] add e2eTest model
new 2cd5006 [e2eTest] add e2eTest model
new b885fa4 [e2eTest] add e2eTest model
new 133ea7e [e2eTest] add e2eTest model
new 8543da8 [e2eTest] add e2eTest model
new 08b9d08 [e2eTest] add e2eTest model
new 7ee73d4 [e2eTest] add e2eTest model
new 8b47ecc [e2eTest] add e2eTest model
new c37ad1b [e2eTest] add e2eTest model
new 6be3034 [e2eTest] add license header
new 9ecd538 [e2eTest] add license header
The 33 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/maven-package.yml| 57 +++
.github/workflows/maven-publish.yml| 34 ---
.../runtime/src/main/resources/runtime.properties | 2 +-
{start => dist}/pom.xml| 55 +++---
dist/src/main/assembly/assembly.xml| 35 +++
{bin => dist/src/main/bin}/eventbridge.sh | 0
{bin => dist/src/main/bin}/runserver.sh| 3 +-
.../src/main/resources/application.properties | 0
.../src/main/resources/logback.xml | 0
pom.xml| 15 +++
start/pom.xml | 22 ++--
start/src/main/resources/application.properties| 2 +-
.../apache/rocketmq/connect/sink/FileSinkTask.java | 3 +-
test/pom.xml | 1 +
.../rocketmq-eventbridge-e2etest}/pom.xml | 61 +--
.../rocketmq/eventbridge/e2etest/BaseTest.java | 111 +
.../controller/ApplicationTagControllerTest.java | 80 +++
.../rocketmq/eventbridge/e2etest/util/Utils.java | 65
18 files changed, 431 insertions(+), 115 deletions(-)
delete mode 100644 .github/workflows/maven-publish.yml
copy {start => dist}/pom.xml (74%)
create mode 100644 dist/src/main/assembly/assembly.xml
rename {bin => dist/src/main/bin}/eventbridge.sh (100%)
rename {bin => dist/src/main/bin}/runserver.sh (97%)
copy {start => dist}/src/main/resources/application.properties (100%)
copy start/src/main/resources/logback-spring.xml =>
dist/src/main/resources/logback.xml (100%)
copy {adapter/rpc => test/rocketmq-eventbridge-e2etest}/pom.xml (59%)
create mode 100644
test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/BaseTest.java
create mode 100644
test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
create mode 100644
test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/util/Utils.java
(rocketmq-eventbridge) 14/33: [e2eTest] add e2eTest model
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit 5426245f2652e7c4ea2c274bea5b4f92eccb783e
Author: wangkai
AuthorDate: Sat Oct 21 11:21:33 2023 +0800
[e2eTest] add e2eTest model
---
.../{maven-publish.yml => maven-package.yml} | 6 ++-
{start => dist}/pom.xml| 57 ++--
dist/src/main/assembly/assembly.xml| 35
{bin => dist/src/main/bin}/eventbridge.sh | 0
{bin => dist/src/main/bin}/runserver.sh| 3 +-
dist/src/main/resources/application.properties | 41 ++
dist/src/main/resources/logback.xml| 63 ++
pom.xml| 1 +
start/pom.xml | 26 -
test/rocketmq-eventbridge-e2etest/pom.xml | 2 +-
.../controller/ApplicationTagControllerTest.java | 38 ++---
.../rocketmq/eventbridge/e2etest/util/Utils.java | 43 ++-
12 files changed, 243 insertions(+), 72 deletions(-)
diff --git a/.github/workflows/maven-publish.yml
b/.github/workflows/maven-package.yml
similarity index 95%
rename from .github/workflows/maven-publish.yml
rename to .github/workflows/maven-package.yml
index fd183e2..37eb4dc 100644
--- a/.github/workflows/maven-publish.yml
+++ b/.github/workflows/maven-package.yml
@@ -1,7 +1,11 @@
# This workflow will build a package using Maven and then publish it to GitHub
packages when a release is created
# For more information see:
https://github.com/actions/setup-java/blob/main/docs/advanced-usage.md#apache-maven-with-a-settings-path
name: Redis runner example
-on: push
+on:
+ pull_request:
+types: [ opened, reopened, synchronize ]
+release:
+ types: [ created ]
jobs:
# Label of the runner job
diff --git a/start/pom.xml b/dist/pom.xml
similarity index 74%
copy from start/pom.xml
copy to dist/pom.xml
index a7e115d..8990d41 100644
--- a/start/pom.xml
+++ b/dist/pom.xml
@@ -1,15 +1,6 @@
-
-
-http://maven.apache.org/POM/4.0.0";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+
+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";>
rocketmq-eventbridge
@@ -18,7 +9,7 @@
4.0.0
-rocketmq-eventbridge-start
+rocketmq-eventbridge-dist
8
@@ -56,7 +47,7 @@
org.apache.rocketmq
-rocketmq-test-demo
+rocketmq-eventbridge-start
@@ -91,8 +82,7 @@
-
+
+
+
+
+local
+
+true
+
+
+
+
+org.apache.maven.plugins
+maven-assembly-plugin
+
+false
+
+
src/main/assembly/assembly.xml
+
+
+
+
+assembly
+package
+
+single
+
+
+
+
+
+
+
+
+
\ No newline at end of file
diff --git a/dist/src/main/assembly/assembly.xml
b/dist/src/main/assembly/assembly.xml
new file mode 100644
index 000..26b0cc6
--- /dev/null
+++ b/dist/src/main/assembly/assembly.xml
@@ -0,0 +1,35 @@
+http://maven.apache.org/ASSEMBLY/2.0.0";
+ xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
+ xsi:schemaLocation="http://maven.apache.org/ASSEMBLY/2.0.0
http://maven.apache.org/xsd/assembly-2.0.0.xsd";>
+assembly
+
+dir
+
+
+true
+rocketmq-eventbridge
+
+
+/
+
+
org.apache.rocketmq:rocketmq-eventbridge-dist:jar
+
+
rocketmq-eventbridge.jar
+
+
+
+
+
+src/main/bin
+bin/
+0755
+unix
+true
+
+
+src/main/resources
+config/
+0755
+
+
+
\ No newline at end of file
diff --git a/bin/eventbridge.sh b/dist/src/main/bin/eventbridge.sh
similarity index 100%
rename from bin/eventbridge.sh
rename to dist/src/main/bin/eventbridge.sh
diff --git a/bin/runserver.sh b/dist/src/main/bin/runserver.sh
similarity index 97%
rename from bin/runserver.sh
rename to dist/src/main/bin/runserver.sh
index de9541c..dfa7221 100755
--- a
(rocketmq-eventbridge) 02/33: 1.modify maven publish
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit ab2b6e12d784f8d4a0ef3d38ab3db7471be7c070
Author: wangkai
AuthorDate: Mon Sep 18 20:00:35 2023 +0800
1.modify maven publish
---
.github/workflows/maven-publish.yml | 36 +---
azure-pipelines.yml | 28 +++-
2 files changed, 28 insertions(+), 36 deletions(-)
diff --git a/.github/workflows/maven-publish.yml
b/.github/workflows/maven-publish.yml
index e49d5f0..e3c3d8c 100644
--- a/.github/workflows/maven-publish.yml
+++ b/.github/workflows/maven-publish.yml
@@ -1,34 +1,24 @@
# This workflow will build a package using Maven and then publish it to GitHub
packages when a release is created
# For more information see:
https://github.com/actions/setup-java/blob/main/docs/advanced-usage.md#apache-maven-with-a-settings-path
-
-name: Maven Package and Publish
-
-on:
- release:
-types: [created]
+name: Redis runner example
+on: push
jobs:
- build:
-
+ # Label of the runner job
+ runner-job:
+# You must use a Linux environment when using service containers or
container jobs
runs-on: ubuntu-latest
permissions:
contents: read
packages: write
steps:
-- uses: actions/checkout@v3
-- name: Set up JDK 11
- uses: actions/setup-java@v3
- with:
-java-version: '11'
-distribution: 'temurin'
-server-id: github # Value of the distributionManagement/repository/id
field of the pom.xml
-settings-path: ${{ github.workspace }} # location for the settings.xml
file
-
-- name: Build with Maven
- run: mvn -B package --file pom.xml
+ # Downloads a copy of the code in your repository before running CI tests
+ - name: Create RocketMQ container
+run: |
+ docker pull rocketmqinc/rocketmq:4.9.1
+ docker run -d --name rocketmq -p 9876:9876 -v
/path/to/config:/opt/rocketmq-4.9.4/conf apache/rocketmq:4.9.4
-- name: Publish to GitHub Packages Apache Maven
- run: mvn deploy -s $GITHUB_WORKSPACE/settings.xml
- env:
-GITHUB_TOKEN: ${{ github.token }}
+ - name: Wait for RocketMQ container to be ready
+run: |
+ docker exec rocketmq sh -c 'while ! nc -z localhost 9876; do sleep
1; done'
diff --git a/azure-pipelines.yml b/azure-pipelines.yml
index f53e97b..b93cf06 100644
--- a/azure-pipelines.yml
+++ b/azure-pipelines.yml
@@ -3,17 +3,19 @@
# Add steps that build, run tests, deploy, and more:
# https://aka.ms/yaml
-trigger:
-- main
+trigger: none
-pool:
- vmImage: ubuntu-latest
-
-steps:
-- script: echo Hello, world!
- displayName: 'Run a one-line script'
-
-- script: |
-echo Add other tasks to build, test, and deploy your project.
-echo See https://aka.ms/yaml
- displayName: 'Run a multi-line script'
+jobs:
+ - job: RunTest
+workspace:
+ clean: all
+pool:
+ vmImage: 'ubuntu-latest'
+steps:
+ - task: Docker@2
+displayName: Login to ACR
+inputs:
+ command: login
+ containerRegistry: my-acr
+ - script: |
+ docker run my-registry.azurecr.io/somerepo/rnd-hello:latest
(rocketmq-eventbridge) 10/33: 1.修改mvn publish文件
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit 42f79ea0cb412564c178c8b69da0ea5d50b11e5b
Author: wangkai
AuthorDate: Wed Sep 20 12:06:43 2023 +0800
1.修改mvn publish文件
---
.github/workflows/maven-publish.yml| 10 ++-
pom.xml| 11 +++
start/pom.xml | 6 +-
test/pom.xml | 1 +
test/rocketmq-eventbridge-e2etest/pom.xml | 49 +++
.../rocketmq/eventbridge/e2etest/BaseTest.java | 95 ++
.../controller/ApplicationTagControllerTest.java | 32
.../rocketmq/eventbridge/e2etest/util/Utils.java | 62 ++
8 files changed, 262 insertions(+), 4 deletions(-)
diff --git a/.github/workflows/maven-publish.yml
b/.github/workflows/maven-publish.yml
index 6431cd8..b862f9e 100644
--- a/.github/workflows/maven-publish.yml
+++ b/.github/workflows/maven-publish.yml
@@ -17,8 +17,16 @@ jobs:
- name: Create RocketMQ container
run: |
docker pull apache/rocketmq:4.9.4
+ echo 'brokerClusterName = DefaultCluster
+brokerName = broker-a
+brokerId = 0
+deleteWhen = 04
+fileReservedTime = 48
+brokerRole = ASYNC_MASTER
+flushDiskType = ASYNC_FLUSH
+brokerIP1 =127.0.0.1'>>./broker.conf
docker run -d --name rmqnamesrv -p 9876:9876 apache/rocketmq:4.9.4
sh mqnamesrv autoCreateTopicEnable=true
- docker run -d --name rmqbroker -p 10911:10911 -p 10909:10909 -e
"NAMESRV_ADDR=127.0.0.1:9876" apache/rocketmq:4.9.4 sh mqbroker
autoCreateTopicEnable=true
+ docker run -d --name rmqbroker -p 10911:10911 -p 10909:10909 --link
rmqnamesrv:namesrv -v ./broker.conf:/opt/rocketmq:4.9.4/conf/broker.conf -e
"NAMESRV_ADDR=rmqnamesrv:9876" apache/rocketmq:4.9.4 sh mqbroker
autoCreateTopicEnable=true -c /opt/rocketmq-4.4.0/conf/broker.conf
- name: Wait for RocketMQ namesrv container to be ready
run: |
diff --git a/pom.xml b/pom.xml
index f3d1bcb..dd83d24 100644
--- a/pom.xml
+++ b/pom.xml
@@ -111,6 +111,11 @@
+
+org.apache.rocketmq
+rocketmq-eventbridge-start
+${project.version}
+
org.apache.rocketmq
rocketmq-eventbridge-adapter-persistence
@@ -157,6 +162,12 @@
${project.version}
+
+org.apache.rocketmq
+rocketmq-eventbridge-e2etest
+${project.version}
+
+
org.springframework.boot
diff --git a/start/pom.xml b/start/pom.xml
index e1e1995..a7e115d 100644
--- a/start/pom.xml
+++ b/start/pom.xml
@@ -91,7 +91,7 @@
-
+
\ No newline at end of file
diff --git a/test/pom.xml b/test/pom.xml
index 12f4a80..c51e371 100644
--- a/test/pom.xml
+++ b/test/pom.xml
@@ -23,6 +23,7 @@
demo
+rocketmq-eventbridge-e2etest
\ No newline at end of file
diff --git a/test/rocketmq-eventbridge-e2etest/pom.xml
b/test/rocketmq-eventbridge-e2etest/pom.xml
new file mode 100644
index 000..8ded330
--- /dev/null
+++ b/test/rocketmq-eventbridge-e2etest/pom.xml
@@ -0,0 +1,49 @@
+
+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";>
+
+rocketmq-eventbridge-test
+org.apache.rocketmq
+1.0.0
+../pom.xml
+
+
+4.0.0
+
+rocketmq-eventbridge-e2etest
+
+
+8
+8
+
+
+
+
+org.apache.rocketmq
+rocketmq-eventbridge-start
+
+
+junit
+junit
+4.13.2
+
+
+org.mockito
+mockito-core
+test
+
+
+org.springframework.boot
+spring-boot-starter-test
+test
+
+
+org.ow2.asm
+asm
+
+
+
+
+
+
\ No newline at end of file
diff --git
a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/BaseTest.java
b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/BaseTest.java
new file mode 100644
index 000..5e6248e
--- /dev/null
+++
b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/BaseTest.java
@@ -0,0 +1,95 @@
+package org.apache.rocketmq.eventbridge.e2etest;
+
+import com.fasterxml.jackson.core.JsonP
(rocketmq-eventbridge) 03/33: 1.modify maven publish
This is an automated email from the ASF dual-hosted git repository. shenlin pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git commit 2b1cee97daa60c33061175f85a21baa0fbf38063 Author: wangkai AuthorDate: Tue Sep 19 00:57:41 2023 +0800 1.modify maven publish --- .github/workflows/maven-publish.yml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/.github/workflows/maven-publish.yml b/.github/workflows/maven-publish.yml index e3c3d8c..bf6afe1 100644 --- a/.github/workflows/maven-publish.yml +++ b/.github/workflows/maven-publish.yml @@ -16,8 +16,8 @@ jobs: # Downloads a copy of the code in your repository before running CI tests - name: Create RocketMQ container run: | - docker pull rocketmqinc/rocketmq:4.9.1 - docker run -d --name rocketmq -p 9876:9876 -v /path/to/config:/opt/rocketmq-4.9.4/conf apache/rocketmq:4.9.4 + docker pull apache/rocketmq:4.9.4 + docker run -d --name rmqnamesrv -p 9876:9876 apache/rocketmq:4.9.4 sh mqnamesrv autoCreateTopicEnable=true - name: Wait for RocketMQ container to be ready run: |
(rocketmq-eventbridge) 23/33: [e2eTest] add e2eTest model
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit 149b0112845f7a4347e8bded9e62307b534b4696
Author: wangkai
AuthorDate: Fri Nov 3 14:18:41 2023 +0800
[e2eTest] add e2eTest model
---
.../src/main/java/org/apache/rocketmq/connect/sink/FileSinkTask.java | 1 +
.../eventbridge/e2etest/controller/ApplicationTagControllerTest.java | 4 ++--
2 files changed, 3 insertions(+), 2 deletions(-)
diff --git
a/supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileSinkTask.java
b/supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileSinkTask.java
index 39526cd..197e34e 100644
---
a/supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileSinkTask.java
+++
b/supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileSinkTask.java
@@ -44,6 +44,7 @@ public class FileSinkTask extends SinkTask {
throw new ConnectException("Write record to file failed.", e);
}
}
+outputStream.flush();
}
diff --git
a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
index e2f6b42..562e4cd 100644
---
a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
+++
b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
@@ -40,7 +40,7 @@ public class ApplicationTagControllerTest extends BaseTest {
ResponseEntity response = Utils.request(template, url,
HttpMethod.POST, "A test recrod.", Void.class, headers);
Assert.assertTrue(response.getStatusCode().is2xxSuccessful());
-File file = new File("/home/runner/demo");
+File file = new File(System.getProperty("user.home") +"/demo");
String data = null;
int retries = 0;
while( retries < 10 ) {
@@ -48,7 +48,7 @@ public class ApplicationTagControllerTest extends BaseTest {
if (StringUtils.isNotBlank(data)) {
break;
}
-Thread.sleep(5);
+Thread.sleep(5000);
retries++;
}
Assert.assertEquals("A test recrod.\n", data);
(rocketmq-eventbridge) 27/33: [e2eTest] add e2eTest model
This is an automated email from the ASF dual-hosted git repository. shenlin pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git commit 8543da850e5d97bef36eec22b052aaf705051183 Author: wangkai AuthorDate: Fri Nov 3 16:44:24 2023 +0800 [e2eTest] add e2eTest model --- .github/workflows/maven-package.yml | 2 ++ adapter/runtime/src/main/resources/runtime.properties | 2 +- start/src/main/resources/application.properties | 2 +- 3 files changed, 4 insertions(+), 2 deletions(-) diff --git a/.github/workflows/maven-package.yml b/.github/workflows/maven-package.yml index e3b2773..00686d7 100644 --- a/.github/workflows/maven-package.yml +++ b/.github/workflows/maven-package.yml @@ -24,6 +24,8 @@ jobs: fileReservedTime = 48 brokerRole = ASYNC_MASTER flushDiskType = ASYNC_FLUSH +autoCreateTopicEnable = true +autoCreateSubscriptionGroup = true brokerIP1 =127.0.0.1'>>/opt/broker.conf docker run -d --name rmqnamesrv -p 9876:9876 apache/rocketmq:4.9.4 sh mqnamesrv autoCreateTopicEnable=true docker run -d --name rmqbroker -p 10911:10911 -p 10909:10909 --link rmqnamesrv:namesrv -v /opt/broker.conf:/opt/rocketmq-4.9.4/conf/broker.conf -e "NAMESRV_ADDR=rmqnamesrv:9876" apache/rocketmq:4.9.4 sh mqbroker autoCreateTopicEnable=true -c /opt/rocketmq-4.9.4/conf/broker.conf diff --git a/adapter/runtime/src/main/resources/runtime.properties b/adapter/runtime/src/main/resources/runtime.properties index b99c83d..84dfa17 100644 --- a/adapter/runtime/src/main/resources/runtime.properties +++ b/adapter/runtime/src/main/resources/runtime.properties @@ -14,7 +14,7 @@ # limitations under the License. ## rocketmq -rocketmq.namesrvAddr=localhost:9876 +rocketmq.namesrvAddr=127.0.0.1:9876 rocketmq.consumer.pullTimeOut = 3000 rocketmq.consumer.pullBatchSize=20 rocketmq.cluster.name=DefaultCluster diff --git a/start/src/main/resources/application.properties b/start/src/main/resources/application.properties index 5911b30..35547c9 100644 --- a/start/src/main/resources/application.properties +++ b/start/src/main/resources/application.properties @@ -25,7 +25,7 @@ spring.profiles.active=local mybatis.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl ## flyway ## rocketmq -rocketmq.namesrvAddr=localhost:9876 +rocketmq.namesrvAddr=127.0.0.1:9876 rocketmq.cluster.name=DefaultCluster ## runtime
(rocketmq-eventbridge) 29/33: [e2eTest] add e2eTest model
This is an automated email from the ASF dual-hosted git repository. shenlin pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git commit 7ee73d41d52558faee73ff9c216b4fded31ae478 Author: wangkai AuthorDate: Fri Nov 3 17:16:25 2023 +0800 [e2eTest] add e2eTest model --- .github/workflows/maven-package.yml | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/.github/workflows/maven-package.yml b/.github/workflows/maven-package.yml index 00686d7..a633c1f 100644 --- a/.github/workflows/maven-package.yml +++ b/.github/workflows/maven-package.yml @@ -16,7 +16,7 @@ jobs: # Downloads a copy of the code in your repository before running CI tests - name: Create RocketMQ container run: | - docker pull apache/rocketmq:4.9.4 + docker pull apache/rocketmq:5.1.0 echo 'brokerClusterName = DefaultCluster brokerName = broker-a brokerId = 0 @@ -27,8 +27,8 @@ jobs: autoCreateTopicEnable = true autoCreateSubscriptionGroup = true brokerIP1 =127.0.0.1'>>/opt/broker.conf - docker run -d --name rmqnamesrv -p 9876:9876 apache/rocketmq:4.9.4 sh mqnamesrv autoCreateTopicEnable=true - docker run -d --name rmqbroker -p 10911:10911 -p 10909:10909 --link rmqnamesrv:namesrv -v /opt/broker.conf:/opt/rocketmq-4.9.4/conf/broker.conf -e "NAMESRV_ADDR=rmqnamesrv:9876" apache/rocketmq:4.9.4 sh mqbroker autoCreateTopicEnable=true -c /opt/rocketmq-4.9.4/conf/broker.conf + docker run -d --name rmqnamesrv -p 9876:9876 apache/rocketmq:5.1.0 sh mqnamesrv autoCreateTopicEnable=true + docker run -d --name rmqbroker -p 10911:10911 -p 10909:10909 --link rmqnamesrv:namesrv -v /opt/broker.conf:/opt/rocketmq-5.1.0/conf/broker.conf -e "NAMESRV_ADDR=rmqnamesrv:9876" apache/rocketmq:5.1.0 sh mqbroker autoCreateTopicEnable=true -c /opt/rocketmq-5.1.0/conf/broker.conf - name: Wait for RocketMQ namesrv container to be ready run: |
(rocketmq-eventbridge) 12/33: 1.修改docker run命令
This is an automated email from the ASF dual-hosted git repository. shenlin pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git commit a82229c74f8b281069aee01217348e65e407e38c Author: wangkai AuthorDate: Wed Sep 20 12:44:03 2023 +0800 1.修改docker run命令 --- .github/workflows/maven-publish.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/.github/workflows/maven-publish.yml b/.github/workflows/maven-publish.yml index f039b22..4454812 100644 --- a/.github/workflows/maven-publish.yml +++ b/.github/workflows/maven-publish.yml @@ -24,7 +24,7 @@ jobs: fileReservedTime = 48 brokerRole = ASYNC_MASTER flushDiskType = ASYNC_FLUSH -brokerIP1 =127.0.0.1'>>./broker.conf +brokerIP1 =127.0.0.1'>>/opt/broker.conf docker run -d --name rmqnamesrv -p 9876:9876 apache/rocketmq:4.9.4 sh mqnamesrv autoCreateTopicEnable=true docker run -d --name rmqbroker -p 10911:10911 -p 10909:10909 --link rmqnamesrv:namesrv -v ./broker.conf:/opt/rocketmq-4.9.4/conf/broker.conf -e "NAMESRV_ADDR=rmqnamesrv:9876" apache/rocketmq:4.9.4 sh mqbroker autoCreateTopicEnable=true -c /opt/rocketmq-4.9.4/conf/broker.conf
(rocketmq-eventbridge) 22/33: [e2eTest] add e2eTest model
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit 8ad96c87eb80642599bb930b91d143f27fe8489f
Author: wangkai
AuthorDate: Mon Oct 23 22:03:55 2023 +0800
[e2eTest] add e2eTest model
---
.../src/main/java/org/apache/rocketmq/eventbridge/demo/DefaultDemo.java | 2 +-
.../eventbridge/e2etest/controller/ApplicationTagControllerTest.java| 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/test/demo/src/main/java/org/apache/rocketmq/eventbridge/demo/DefaultDemo.java
b/test/demo/src/main/java/org/apache/rocketmq/eventbridge/demo/DefaultDemo.java
index ce71c7a..d9e2b37 100644
---
a/test/demo/src/main/java/org/apache/rocketmq/eventbridge/demo/DefaultDemo.java
+++
b/test/demo/src/main/java/org/apache/rocketmq/eventbridge/demo/DefaultDemo.java
@@ -94,7 +94,7 @@ public class DefaultDemo {
if (eventTargets == null || eventTargets.isEmpty()) {
List eventTargetList = Lists.newArrayList();
Map config = Maps.newHashMap();
-config.put("fileName", System.getProperty("user.home") + "/demo");
+config.put("fileName", "/home/runner/demo");
config.put("line", "{\"form\":\"JSONPATH\",\"value\":\"$.data\"}");
EventTarget eventTarget =
EventTarget.builder().name(DEFAULT_EVENT_TARGET_NAME).className(DEFAULT_EVENT_TARGET_CLASS).config(config).build();
eventTargetList.add(eventTarget);
diff --git
a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
index 3a6e284..e2f6b42 100644
---
a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
+++
b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
@@ -40,7 +40,7 @@ public class ApplicationTagControllerTest extends BaseTest {
ResponseEntity response = Utils.request(template, url,
HttpMethod.POST, "A test recrod.", Void.class, headers);
Assert.assertTrue(response.getStatusCode().is2xxSuccessful());
-File file = new File(System.getProperty("user.home") + "/demo");
+File file = new File("/home/runner/demo");
String data = null;
int retries = 0;
while( retries < 10 ) {
(rocketmq-eventbridge) 25/33: [e2eTest] add e2eTest model
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit b885fa4e7b8f7caaa7761b97686b37a83d797446
Author: wangkai
AuthorDate: Fri Nov 3 16:00:22 2023 +0800
[e2eTest] add e2eTest model
---
.github/workflows/maven-package.yml | 4 +---
.../src/main/java/org/apache/rocketmq/connect/sink/FileSinkTask.java | 2 +-
2 files changed, 2 insertions(+), 4 deletions(-)
diff --git a/.github/workflows/maven-package.yml
b/.github/workflows/maven-package.yml
index 02de6d3..e3b2773 100644
--- a/.github/workflows/maven-package.yml
+++ b/.github/workflows/maven-package.yml
@@ -34,9 +34,7 @@ jobs:
- name: Wait for RocketMQ broker container to be ready
run: |
- docker exec rmqbroker sh -c 'while ! nc -z localhost 10911; do sleep
1; done'
- - name : create output file
-run: touch /home/runner/demo
+ docker exec rmqbroker sh -c 'while ! nc -z localhost 10911; do sleep
1; done'
- uses: actions/checkout@v3
- name: Set up JDK 8
uses: actions/setup-java@v3
diff --git
a/supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileSinkTask.java
b/supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileSinkTask.java
index 197e34e..8acca33 100644
---
a/supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileSinkTask.java
+++
b/supports/eventbridge-connect-file/src/main/java/org/apache/rocketmq/connect/sink/FileSinkTask.java
@@ -30,7 +30,7 @@ import java.nio.file.StandardOpenOption;
import java.util.List;
public class FileSinkTask extends SinkTask {
-private String fileName = System.getProperty("user.home") +
"/demo.eventbridge";
+private String fileName = System.getProperty("user.home") + "/demo";
private PrintStream outputStream;
@Override public void put(List sinkRecords) throws
ConnectException {
(rocketmq-eventbridge) 09/33: 1.修改mvn publish文件
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit 8d9fd6949511cdcd4887d1302379031b78a22803
Author: wangkai
AuthorDate: Tue Sep 19 13:52:16 2023 +0800
1.修改mvn publish文件
---
.github/workflows/maven-publish.yml | 5 -
1 file changed, 5 deletions(-)
diff --git a/.github/workflows/maven-publish.yml
b/.github/workflows/maven-publish.yml
index 7ad8aa5..6431cd8 100644
--- a/.github/workflows/maven-publish.yml
+++ b/.github/workflows/maven-publish.yml
@@ -39,8 +39,3 @@ jobs:
- name: Build with Maven
run: mvn -B package --file pom.xml
-
- - name: Publish to GitHub Packages Apache Maven
-run: mvn deploy -s $GITHUB_WORKSPACE/settings.xml
-env:
- GITHUB_TOKEN: ${{ github.token }}
(rocketmq-eventbridge) 04/33: 1.modify maven publish
This is an automated email from the ASF dual-hosted git repository. shenlin pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git commit bffd1fb56dedb8265a1502271508ee41979aafd7 Author: wangkai AuthorDate: Tue Sep 19 01:00:34 2023 +0800 1.modify maven publish --- .github/workflows/maven-publish.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/.github/workflows/maven-publish.yml b/.github/workflows/maven-publish.yml index bf6afe1..b20c7cb 100644 --- a/.github/workflows/maven-publish.yml +++ b/.github/workflows/maven-publish.yml @@ -21,4 +21,4 @@ jobs: - name: Wait for RocketMQ container to be ready run: | - docker exec rocketmq sh -c 'while ! nc -z localhost 9876; do sleep 1; done' + docker exec rmqnamesrv sh -c 'while ! nc -z localhost 9876; do sleep 1; done'
Re: [PR] [e2eTest] add e2eTest model [rocketmq-eventbridge]
2011shenlin merged PR #153: URL: https://github.com/apache/rocketmq-eventbridge/pull/153 -- 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-eventbridge) branch feat/runtime-manager updated: feat:watch the cluster and worker.
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch feat/runtime-manager
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
The following commit(s) were added to refs/heads/feat/runtime-manager by this
push:
new 81f7bc3 feat:watch the cluster and worker.
81f7bc3 is described below
commit 81f7bc3ae92115039bffb1f8cf9671ed5073b56a
Author: 2011shenlin <2011shen...@gmail.com>
AuthorDate: Sun Nov 26 19:31:43 2023 +0800
feat:watch the cluster and worker.
---
adapter/persistence/pom.xml| 5 +
.../mybatis/mapper/EventClusterMapper.java}| 10 +-
.../repository/MybatisClusterRepository.java} | 25 +-
.../worker/mybatis/mapper/EventWorkerMapper.java} | 21 +-
.../repository/MybatisWorkerRepository.java| 54 ++
.../resources/db/migration/V10__init_cluster.sql | 30 +
.../resources/db/migration/V11__init_worker.sql| 32 +
.../main/resources/mybatis/EventClusterMapper.xml | 52 ++
.../main/resources/mybatis/EventWorkerMapper.xml | 63 ++
adapter/pom.xml| 1 +
.../adapter/runtime/manager/cluster/Cluster.java | 7 +-
.../runtime/manager/cluster/ClusterService.java| 10 +-
.../manager/repository/ClusterRepository.java | 2 +-
.../manager/repository/WorkerRepository.java | 4 +-
.../runtime/manager/scale/ClusterWorkerScale.java | 2 +
.../runtime/manager/watch/WatchCluster.java| 48 +-
.../adapter/runtime/manager/watch/WatchWorker.java | 37 +-
.../adapter/runtime/manager/worker/Worker.java | 12 +-
.../runtime/manager/worker/WorkerService.java | 20 +-
pom.xml| 10 +-
rocketmq_eventbridge.mv.db | Bin 81920 -> 81920 bytes
rocketmq_eventbridge.trace.db | 657 +++--
scan.py| 0
start/pom.xml | 13 +-
.../rocketmq/eventbridge/demo/DefaultDemo.java | 6 +-
25 files changed, 467 insertions(+), 654 deletions(-)
diff --git a/adapter/persistence/pom.xml b/adapter/persistence/pom.xml
index eac0c8e..b206a1d 100644
--- a/adapter/persistence/pom.xml
+++ b/adapter/persistence/pom.xml
@@ -71,6 +71,11 @@
org.apache.rocketmq
rocketmq-tools
+
+
rocketmq-eventbridge-adapter-runtime-manager
+org.apache.rocketmq
+1.0.0
+
org.flywaydb
flyway-core
diff --git
a/adapter/runtime-manager/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/manager/repository/ClusterRepository.java
b/adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/cluster/mybatis/mapper/EventClusterMapper.java
similarity index 79%
copy from
adapter/runtime-manager/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/manager/repository/ClusterRepository.java
copy to
adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/cluster/mybatis/mapper/EventClusterMapper.java
index 38c1c58..ea62dc5 100644
---
a/adapter/runtime-manager/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/manager/repository/ClusterRepository.java
+++
b/adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/cluster/mybatis/mapper/EventClusterMapper.java
@@ -15,14 +15,14 @@
* limitations under the License.
*/
-package org.apache.rocketmq.eventbridge.adapter.runtime.manager.repository;
+package
org.apache.rocketmq.eventbridge.adapter.persistence.cluster.mybatis.mapper;
import java.util.List;
+import org.apache.ibatis.annotations.Param;
import org.apache.rocketmq.eventbridge.adapter.runtime.manager.cluster.Cluster;
-public interface ClusterRepository {
-
+public interface EventClusterMapper {
List listCluster();
-boolean updateCluster(Cluster cluster);
-}
+int updateCluster(@Param("id") int id, @Param("md5") String md5);
+}
\ No newline at end of file
diff --git
a/adapter/runtime-manager/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/manager/repository/ClusterRepository.java
b/adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/cluster/mybatis/repository/MybatisClusterRepository.java
similarity index 51%
copy from
adapter/runtime-manager/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/manager/repository/ClusterRepository.java
copy to
adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/cluster/mybatis/repository/MybatisClusterRepository.java
index 38c1c58..19ad2da 100644
---
a/adapter/runtime-manager/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/manager/repository/ClusterRepository.java
+++
b/adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/cluster/myb
(rocketmq-eventbridge) 26/33: [e2eTest] add e2eTest model
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit 133ea7eac20c16225bcc2f45c3b6e7be21c6d23e
Author: wangkai
AuthorDate: Fri Nov 3 16:28:08 2023 +0800
[e2eTest] add e2eTest model
---
.../eventbridge/e2etest/controller/ApplicationTagControllerTest.java | 4
1 file changed, 4 insertions(+)
diff --git
a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
index e7b743a..416993e 100644
---
a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
+++
b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
@@ -41,6 +41,10 @@ public class ApplicationTagControllerTest extends BaseTest {
ResponseEntity response = Utils.request(template, url,
HttpMethod.POST, "A test recrod.", Void.class, headers);
Assert.assertTrue(response.getStatusCode().is2xxSuccessful());
File file = new File(System.getProperty("user.home") +"/demo");
+if (!file.exists()) {
+file.createNewFile();
+}
+
String data = null;
int retries = 0;
while( retries < 10 ) {
(rocketmq-eventbridge) 31/33: [e2eTest] add e2eTest model
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit c37ad1b4b77fd69435a67236710765159e3903f9
Author: wangkai
AuthorDate: Fri Nov 3 18:21:40 2023 +0800
[e2eTest] add e2eTest model
---
.github/workflows/maven-package.yml | 6 +-
.../storage/rocketmq/impl/DefaultSendCallback.java | 4
.../rocketmq/impl/RocketMQEventDataRepository.java | 3 ---
azure-pipelines.yml | 21 -
.../rocketmq/eventbridge/demo/DefaultDemo.java | 2 +-
5 files changed, 6 insertions(+), 30 deletions(-)
diff --git a/.github/workflows/maven-package.yml
b/.github/workflows/maven-package.yml
index a633c1f..c73ebc5 100644
--- a/.github/workflows/maven-package.yml
+++ b/.github/workflows/maven-package.yml
@@ -1,7 +1,11 @@
# This workflow will build a package using Maven and then publish it to GitHub
packages when a release is created
# For more information see:
https://github.com/actions/setup-java/blob/main/docs/advanced-usage.md#apache-maven-with-a-settings-path
name: Redis runner example
-on: push
+on:
+ pull_request:
+types: [ opened, reopened, synchronize ]
+release:
+ types: [ created ]
jobs:
# Label of the runner job
diff --git
a/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/DefaultSendCallback.java
b/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/DefaultSendCallback.java
index d1df650..35bc7ef 100644
---
a/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/DefaultSendCallback.java
+++
b/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/DefaultSendCallback.java
@@ -17,14 +17,12 @@
package org.apache.rocketmq.eventbridge.adapter.storage.rocketmq.impl;
-import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.client.producer.SendCallback;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.eventbridge.domain.model.data.PutEventCallback;
import
org.apache.rocketmq.eventbridge.domain.model.data.PutEventsResponseEntry;
import org.apache.rocketmq.eventbridge.exception.code.DefaultErrorCode;
-@Slf4j
public class DefaultSendCallback implements SendCallback {
PutEventCallback putEventCallback;
@@ -37,7 +35,6 @@ public class DefaultSendCallback implements SendCallback {
@Override
public void onSuccess(SendResult sendResult) {
-log.info("send msg to topic :{} success result.", sendResult);
entry.setEventId(sendResult.getMsgId());
entry.setErrorCode(DefaultErrorCode.Success.getCode());
putEventCallback.endProcess(entry);
@@ -45,7 +42,6 @@ public class DefaultSendCallback implements SendCallback {
@Override
public void onException(Throwable throwable) {
-log.error("send msg to topic : fail result.", throwable);
entry.setErrorCode(DefaultErrorCode.InternalError.getCode());
entry.setErrorMessage(throwable.getMessage());
putEventCallback.endProcess(entry);
diff --git
a/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/RocketMQEventDataRepository.java
b/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/RocketMQEventDataRepository.java
index bf24411..5b1d796 100644
---
a/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/RocketMQEventDataRepository.java
+++
b/adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/RocketMQEventDataRepository.java
@@ -75,11 +75,8 @@ public class RocketMQEventDataRepository implements
EventDataRepository {
String topicName = this.getTopicName(accountId, eventBusName);
Message msg = eventDataOnRocketMQConnectAPI.converter(accountId,
topicName, eventBridgeEvent);
try {
-log.info("send msg to topic :{} before.", topicName);
producer.send(msg, new DefaultSendCallback(putEventCallback),
1000L);
-log.info("send msg to topic :{} end.", topicName);
} catch (Throwable e) {
-log.info("send msg to topic :{} failed. and exception is {}",
topicName, e.toString());
throw new EventBridgeException(EventBridgeErrorCode.InternalError,
e);
}
return true;
diff --git a/azure-pipelines.yml b/azure-pipelines.yml
deleted file mode 100644
index b93cf06..000
--- a/azure-pipelines.yml
+++ /dev/null
@@ -1,21 +0,0 @@
-# Starter pipeline
-# Start with a minimal pipeline that you can customize to build and deploy
your code.
-# Add steps that build, run tests, deploy, and more:
-# https://aka.ms/yaml
-
-trigger: none
-
-jobs:
- - job: RunTest
-workspace:
- clean: all
-pool:
-
(rocketmq-eventbridge) 17/33: [e2eTest] add e2eTest model
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit 41bfec2c2ce8aff95aa04ff203a7feec68a4bd27
Author: wangkai
AuthorDate: Mon Oct 23 10:11:15 2023 +0800
[e2eTest] add e2eTest model
---
.github/workflows/maven-package.yml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/.github/workflows/maven-package.yml
b/.github/workflows/maven-package.yml
index 5688302..02de6d3 100644
--- a/.github/workflows/maven-package.yml
+++ b/.github/workflows/maven-package.yml
@@ -36,7 +36,7 @@ jobs:
run: |
docker exec rmqbroker sh -c 'while ! nc -z localhost 10911; do sleep
1; done'
- name : create output file
-run: touch ${user.home}/demo
+run: touch /home/runner/demo
- uses: actions/checkout@v3
- name: Set up JDK 8
uses: actions/setup-java@v3
(rocketmq-eventbridge) 21/33: [e2eTest] add e2eTest model
This is an automated email from the ASF dual-hosted git repository. shenlin pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git commit 93f643ed67ea2d98f1ceb8577ed543ccdc62328e Author: wangkai AuthorDate: Mon Oct 23 21:34:47 2023 +0800 [e2eTest] add e2eTest model --- .github/workflows/maven-package.yml | 6 +- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/.github/workflows/maven-package.yml b/.github/workflows/maven-package.yml index adec12e..02de6d3 100644 --- a/.github/workflows/maven-package.yml +++ b/.github/workflows/maven-package.yml @@ -1,11 +1,7 @@ # This workflow will build a package using Maven and then publish it to GitHub packages when a release is created # For more information see: https://github.com/actions/setup-java/blob/main/docs/advanced-usage.md#apache-maven-with-a-settings-path name: Redis runner example -on: - pull_request: -types: [ opened, reopened, synchronize ] -release: - types: [ created ] +on: push jobs: # Label of the runner job
(rocketmq-eventbridge) 19/33: [e2eTest] add e2eTest model
This is an automated email from the ASF dual-hosted git repository. shenlin pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git commit 668886efe0e2b0f9cfd1200728de3cb0325f8111 Author: wangkai AuthorDate: Mon Oct 23 21:22:23 2023 +0800 [e2eTest] add e2eTest model --- .github/workflows/maven-package.yml | 6 +- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/.github/workflows/maven-package.yml b/.github/workflows/maven-package.yml index 02de6d3..adec12e 100644 --- a/.github/workflows/maven-package.yml +++ b/.github/workflows/maven-package.yml @@ -1,7 +1,11 @@ # This workflow will build a package using Maven and then publish it to GitHub packages when a release is created # For more information see: https://github.com/actions/setup-java/blob/main/docs/advanced-usage.md#apache-maven-with-a-settings-path name: Redis runner example -on: push +on: + pull_request: +types: [ opened, reopened, synchronize ] +release: + types: [ created ] jobs: # Label of the runner job
(rocketmq-eventbridge) 15/33: [e2eTest] add e2eTest model
This is an automated email from the ASF dual-hosted git repository. shenlin pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git commit 8696a41ec0905eb2b2b4a0dba8ee274d20e1a51a Author: wangkai AuthorDate: Sat Oct 21 11:22:50 2023 +0800 [e2eTest] add e2eTest model --- .github/workflows/maven-package.yml | 6 +- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/.github/workflows/maven-package.yml b/.github/workflows/maven-package.yml index 37eb4dc..fd183e2 100644 --- a/.github/workflows/maven-package.yml +++ b/.github/workflows/maven-package.yml @@ -1,11 +1,7 @@ # This workflow will build a package using Maven and then publish it to GitHub packages when a release is created # For more information see: https://github.com/actions/setup-java/blob/main/docs/advanced-usage.md#apache-maven-with-a-settings-path name: Redis runner example -on: - pull_request: -types: [ opened, reopened, synchronize ] -release: - types: [ created ] +on: push jobs: # Label of the runner job
(rocketmq-eventbridge) 33/33: [e2eTest] add license header
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit 9ecd53824062229d6f46be2758ee26f278baad8c
Author: wangkai
AuthorDate: Tue Nov 21 19:40:22 2023 +0800
[e2eTest] add license header
---
maven-package.yml.bak | 31 ---
1 file changed, 31 deletions(-)
diff --git a/maven-package.yml.bak b/maven-package.yml.bak
deleted file mode 100644
index c3f3a65..000
--- a/maven-package.yml.bak
+++ /dev/null
@@ -1,31 +0,0 @@
-# This workflow will build a package using Maven and then publish it to GitHub
packages when a release is created
-# For more information see:
https://github.com/actions/setup-java/blob/main/docs/advanced-usage.md#apache-maven-with-a-settings-path
-
-name: Maven Test And Package
-
-on:
- pull_request:
-types: [ opened, reopened, synchronize ]
- release:
-types: [created]
-
-jobs:
- build:
-
-runs-on: ubuntu-latest
-permissions:
- contents: read
- packages: write
-
-steps:
-- uses: actions/checkout@v3
-- name: Set up JDK 8
- uses: actions/setup-java@v3
- with:
-java-version: '8'
-distribution: 'temurin'
-server-id: github # Value of the distributionManagement/repository/id
field of the pom.xml
-settings-path: ${{ github.workspace }} # location for the settings.xml
file
-
-- name: Build with Maven
- run: mvn -B package --file pom.xml
\ No newline at end of file
(rocketmq-eventbridge) 24/33: [e2eTest] add e2eTest model
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit 2cd50065578990ea8e17409d8f49373dd560044e
Author: wangkai
AuthorDate: Fri Nov 3 15:17:09 2023 +0800
[e2eTest] add e2eTest model
---
.../src/main/java/org/apache/rocketmq/eventbridge/demo/DefaultDemo.java | 2 +-
.../eventbridge/e2etest/controller/ApplicationTagControllerTest.java| 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/test/demo/src/main/java/org/apache/rocketmq/eventbridge/demo/DefaultDemo.java
b/test/demo/src/main/java/org/apache/rocketmq/eventbridge/demo/DefaultDemo.java
index d9e2b37..f807f12 100644
---
a/test/demo/src/main/java/org/apache/rocketmq/eventbridge/demo/DefaultDemo.java
+++
b/test/demo/src/main/java/org/apache/rocketmq/eventbridge/demo/DefaultDemo.java
@@ -94,7 +94,7 @@ public class DefaultDemo {
if (eventTargets == null || eventTargets.isEmpty()) {
List eventTargetList = Lists.newArrayList();
Map config = Maps.newHashMap();
-config.put("fileName", "/home/runner/demo");
+config.put("fileName", System.getProperty("user.home")+"/demo");
config.put("line", "{\"form\":\"JSONPATH\",\"value\":\"$.data\"}");
EventTarget eventTarget =
EventTarget.builder().name(DEFAULT_EVENT_TARGET_NAME).className(DEFAULT_EVENT_TARGET_CLASS).config(config).build();
eventTargetList.add(eventTarget);
diff --git
a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
index 562e4cd..e7b743a 100644
---
a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
+++
b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
@@ -48,7 +48,7 @@ public class ApplicationTagControllerTest extends BaseTest {
if (StringUtils.isNotBlank(data)) {
break;
}
-Thread.sleep(5000);
+Thread.sleep(5);
retries++;
}
Assert.assertEquals("A test recrod.\n", data);
(rocketmq-eventbridge) 01/33: Set up CI with Azure Pipelines
This is an automated email from the ASF dual-hosted git repository. shenlin pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git commit 1ff638e925867f2e611cf144625b208396bf5115 Author: yiduwangkai <16093572+yiduwang...@users.noreply.github.com> AuthorDate: Mon Aug 28 00:31:03 2023 +0800 Set up CI with Azure Pipelines [skip ci] --- azure-pipelines.yml | 19 +++ 1 file changed, 19 insertions(+) diff --git a/azure-pipelines.yml b/azure-pipelines.yml new file mode 100644 index 000..f53e97b --- /dev/null +++ b/azure-pipelines.yml @@ -0,0 +1,19 @@ +# Starter pipeline +# Start with a minimal pipeline that you can customize to build and deploy your code. +# Add steps that build, run tests, deploy, and more: +# https://aka.ms/yaml + +trigger: +- main + +pool: + vmImage: ubuntu-latest + +steps: +- script: echo Hello, world! + displayName: 'Run a one-line script' + +- script: | +echo Add other tasks to build, test, and deploy your project. +echo See https://aka.ms/yaml + displayName: 'Run a multi-line script'
(rocketmq-eventbridge) 16/33: [e2eTest] add e2eTest model
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit 101056a04c9ff397f7c1d65a0a22b7f3de80caec
Author: wangkai
AuthorDate: Sun Oct 22 23:43:00 2023 +0800
[e2eTest] add e2eTest model
---
.github/workflows/maven-package.yml | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/.github/workflows/maven-package.yml
b/.github/workflows/maven-package.yml
index fd183e2..5688302 100644
--- a/.github/workflows/maven-package.yml
+++ b/.github/workflows/maven-package.yml
@@ -35,7 +35,8 @@ jobs:
- name: Wait for RocketMQ broker container to be ready
run: |
docker exec rmqbroker sh -c 'while ! nc -z localhost 10911; do sleep
1; done'
-
+ - name : create output file
+run: touch ${user.home}/demo
- uses: actions/checkout@v3
- name: Set up JDK 8
uses: actions/setup-java@v3
(rocketmq-eventbridge) 18/33: [e2eTest] add e2eTest model
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit bf89b28696cd41e64e3316d57585a8c09d836e4a
Author: wangkai
AuthorDate: Mon Oct 23 21:01:17 2023 +0800
[e2eTest] add e2eTest model
---
pom.xml | 3 +++
test/rocketmq-eventbridge-e2etest/pom.xml| 20
.../controller/ApplicationTagControllerTest.java | 14 +++---
3 files changed, 30 insertions(+), 7 deletions(-)
diff --git a/pom.xml b/pom.xml
index b60d031..7854332 100644
--- a/pom.xml
+++ b/pom.xml
@@ -105,6 +105,9 @@
domain
common
infrastructure
+supports/connect-eventbridge-transform
+supports/connect-filter-transform
+supports/eventbridge-connect-file
test
dist
diff --git a/test/rocketmq-eventbridge-e2etest/pom.xml
b/test/rocketmq-eventbridge-e2etest/pom.xml
index ac82308..e5abdb9 100644
--- a/test/rocketmq-eventbridge-e2etest/pom.xml
+++ b/test/rocketmq-eventbridge-e2etest/pom.xml
@@ -44,6 +44,26 @@
+
+org.apache.rocketmq
+connect-eventbridge-transform
+1.0.0-SNAPSHOT
+
+
+org.apache.rocketmq
+connect-eventbridge-transform
+1.0.0-SNAPSHOT
+
+
+org.apache.rocketmq
+connect-filter-transform
+1.0.0-SNAPSHOT
+
+
+org.apache.rocketmq
+eventbridge-connect-file
+1.0.0-SNAPSHOT
+
\ No newline at end of file
diff --git
a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
index bac500b..7998783 100644
---
a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
+++
b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
@@ -2,6 +2,7 @@ package org.apache.rocketmq.eventbridge.e2etest.controller;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.io.FileUtils;
+import org.apache.commons.lang3.StringUtils;
import org.apache.rocketmq.eventbridge.Main;
import org.apache.rocketmq.eventbridge.e2etest.BaseTest;
import org.apache.rocketmq.eventbridge.e2etest.util.Utils;
@@ -39,19 +40,18 @@ public class ApplicationTagControllerTest extends BaseTest {
ResponseEntity response = Utils.request(template, url,
HttpMethod.POST, "A test recrod.", Void.class, headers);
Assert.assertTrue(response.getStatusCode().is2xxSuccessful());
-
File file = new File(System.getProperty("user.home") + "/demo");
String data = null;
-long current = System.currentTimeMillis();
-while((System.currentTimeMillis() - current)/1000 <300 ) {
+int retries = 0;
+while( retries < 10 ) {
data = FileUtils.readFileToString(file, "UTF-8");
-if (data != null) {
+if (StringUtils.isNotBlank(data)) {
+Assert.assertEquals("A test recrod.\n", data);
break;
}
-Thread.sleep(1000);
+Thread.sleep(5);
+retries++;
}
-
-Assert.assertEquals("A test recrod.\n", data);
}
(rocketmq-eventbridge) 30/33: [e2eTest] add e2eTest model
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit 8b47ecc6b49108d0a4147dee7a32f0bb67a4b57b
Author: wangkai
AuthorDate: Fri Nov 3 17:59:36 2023 +0800
[e2eTest] add e2eTest model
---
.../eventbridge/e2etest/controller/ApplicationTagControllerTest.java| 2 ++
1 file changed, 2 insertions(+)
diff --git
a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
index 416993e..f97ab83 100644
---
a/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
+++
b/test/rocketmq-eventbridge-e2etest/src/test/java/org/apache/rocketmq/eventbridge/e2etest/controller/ApplicationTagControllerTest.java
@@ -38,6 +38,8 @@ public class ApplicationTagControllerTest extends BaseTest {
headers.put("ce-time","2018-04-05T17:31:00Z");
headers.put("ce-eventbusname", "demo-bus");
+Thread.sleep(1);
+
ResponseEntity response = Utils.request(template, url,
HttpMethod.POST, "A test recrod.", Void.class, headers);
Assert.assertTrue(response.getStatusCode().is2xxSuccessful());
File file = new File(System.getProperty("user.home") +"/demo");
(rocketmq-eventbridge) 13/33: 1.修改docker run命令
This is an automated email from the ASF dual-hosted git repository. shenlin pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git commit faa1e15bdd3912e425b406adb6b27c0e1360233e Author: wangkai AuthorDate: Wed Sep 20 14:05:23 2023 +0800 1.修改docker run命令 --- .github/workflows/maven-publish.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/.github/workflows/maven-publish.yml b/.github/workflows/maven-publish.yml index 4454812..fd183e2 100644 --- a/.github/workflows/maven-publish.yml +++ b/.github/workflows/maven-publish.yml @@ -26,7 +26,7 @@ jobs: flushDiskType = ASYNC_FLUSH brokerIP1 =127.0.0.1'>>/opt/broker.conf docker run -d --name rmqnamesrv -p 9876:9876 apache/rocketmq:4.9.4 sh mqnamesrv autoCreateTopicEnable=true - docker run -d --name rmqbroker -p 10911:10911 -p 10909:10909 --link rmqnamesrv:namesrv -v ./broker.conf:/opt/rocketmq-4.9.4/conf/broker.conf -e "NAMESRV_ADDR=rmqnamesrv:9876" apache/rocketmq:4.9.4 sh mqbroker autoCreateTopicEnable=true -c /opt/rocketmq-4.9.4/conf/broker.conf + docker run -d --name rmqbroker -p 10911:10911 -p 10909:10909 --link rmqnamesrv:namesrv -v /opt/broker.conf:/opt/rocketmq-4.9.4/conf/broker.conf -e "NAMESRV_ADDR=rmqnamesrv:9876" apache/rocketmq:4.9.4 sh mqbroker autoCreateTopicEnable=true -c /opt/rocketmq-4.9.4/conf/broker.conf - name: Wait for RocketMQ namesrv container to be ready run: |
(rocketmq-eventbridge) 05/33: 1.modify workflows file
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit fab20bcc98bbaf3546804d7e086c5d618d58eaa3
Author: wangkai
AuthorDate: Tue Sep 19 10:10:54 2023 +0800
1.modify workflows file
---
.github/workflows/maven-publish.yml | 24 +++-
1 file changed, 23 insertions(+), 1 deletion(-)
diff --git a/.github/workflows/maven-publish.yml
b/.github/workflows/maven-publish.yml
index b20c7cb..780fdfa 100644
--- a/.github/workflows/maven-publish.yml
+++ b/.github/workflows/maven-publish.yml
@@ -18,7 +18,29 @@ jobs:
run: |
docker pull apache/rocketmq:4.9.4
docker run -d --name rmqnamesrv -p 9876:9876 apache/rocketmq:4.9.4
sh mqnamesrv autoCreateTopicEnable=true
+ docker run -d --name rmqbroker -p 10911:10911 -p 10909:10909 -e
"NAMESRV_ADDR=127.0.0.1:9876" apache/rocketmq:4.9.4 sh mqbroker
autoCreateTopicEnable=true
- - name: Wait for RocketMQ container to be ready
+ - name: Wait for RocketMQ namesrv container to be ready
run: |
docker exec rmqnamesrv sh -c 'while ! nc -z localhost 9876; do sleep
1; done'
+
+ - name: Wait for RocketMQ broker container to be ready
+run: |
+ docker exec rmqbroker sh -c 'while ! nc -z localhost 10911; do sleep
1; done'
+
+ - uses: actions/checkout@v3
+ - name: Set up JDK 11
+uses: actions/setup-java@v3
+with:
+ java-version: '11'
+ distribution: 'temurin'
+ server-id: github # Value of the
distributionManagement/repository/id field of the pom.xml
+ settings-path: ${{ github.workspace }} # location for the
settings.xml file
+
+ - name: Build with Maven
+run: mvn -B package --file pom.xml
+
+ - name: Publish to GitHub Packages Apache Maven
+run: mvn deploy -s $GITHUB_WORKSPACE/settings.xml
+env:
+ GITHUB_TOKEN: ${{ github.token }}
(rocketmq-eventbridge) 11/33: 1.修改docker run命令
This is an automated email from the ASF dual-hosted git repository. shenlin pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git commit 7ac61ee686588eb3327686b1dc294885402e32b4 Author: wangkai AuthorDate: Wed Sep 20 12:10:04 2023 +0800 1.修改docker run命令 --- .github/workflows/maven-publish.yml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/.github/workflows/maven-publish.yml b/.github/workflows/maven-publish.yml index b862f9e..f039b22 100644 --- a/.github/workflows/maven-publish.yml +++ b/.github/workflows/maven-publish.yml @@ -26,7 +26,7 @@ jobs: flushDiskType = ASYNC_FLUSH brokerIP1 =127.0.0.1'>>./broker.conf docker run -d --name rmqnamesrv -p 9876:9876 apache/rocketmq:4.9.4 sh mqnamesrv autoCreateTopicEnable=true - docker run -d --name rmqbroker -p 10911:10911 -p 10909:10909 --link rmqnamesrv:namesrv -v ./broker.conf:/opt/rocketmq:4.9.4/conf/broker.conf -e "NAMESRV_ADDR=rmqnamesrv:9876" apache/rocketmq:4.9.4 sh mqbroker autoCreateTopicEnable=true -c /opt/rocketmq-4.4.0/conf/broker.conf + docker run -d --name rmqbroker -p 10911:10911 -p 10909:10909 --link rmqnamesrv:namesrv -v ./broker.conf:/opt/rocketmq-4.9.4/conf/broker.conf -e "NAMESRV_ADDR=rmqnamesrv:9876" apache/rocketmq:4.9.4 sh mqbroker autoCreateTopicEnable=true -c /opt/rocketmq-4.9.4/conf/broker.conf - name: Wait for RocketMQ namesrv container to be ready run: |
(rocketmq-eventbridge) 08/33: 1.移除文件
This is an automated email from the ASF dual-hosted git repository. shenlin pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git commit 0253e9f977eccab2efae249a600ead9fd7fe82ab Author: wangkai AuthorDate: Tue Sep 19 12:24:53 2023 +0800 1.移除文件 --- .github/workflows/maven-package.yml => maven-package.yml.bak | 0 1 file changed, 0 insertions(+), 0 deletions(-) diff --git a/.github/workflows/maven-package.yml b/maven-package.yml.bak similarity index 100% rename from .github/workflows/maven-package.yml rename to maven-package.yml.bak
(rocketmq-eventbridge) 07/33: 1.modify workflows mvn file
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit 11e4ec32f7b6ef56e91c45a9fa5114a83cf1f974
Author: wangkai
AuthorDate: Tue Sep 19 10:38:02 2023 +0800
1.modify workflows mvn file
---
.github/workflows/maven-publish.yml | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/.github/workflows/maven-publish.yml
b/.github/workflows/maven-publish.yml
index 304b251..7ad8aa5 100644
--- a/.github/workflows/maven-publish.yml
+++ b/.github/workflows/maven-publish.yml
@@ -29,10 +29,10 @@ jobs:
docker exec rmqbroker sh -c 'while ! nc -z localhost 10911; do sleep
1; done'
- uses: actions/checkout@v3
- - name: Set up JDK 1.8
+ - name: Set up JDK 8
uses: actions/setup-java@v3
with:
- java-version: '1.8'
+ java-version: '8'
distribution: 'temurin'
server-id: github # Value of the
distributionManagement/repository/id field of the pom.xml
settings-path: ${{ github.workspace }} # location for the
settings.xml file
(rocketmq-eventbridge) 06/33: 1.modify workflows mvn file
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit bc0e8bb0f29144f7a84e417a451f40879c3aefd3
Author: wangkai
AuthorDate: Tue Sep 19 10:36:21 2023 +0800
1.modify workflows mvn file
---
.github/workflows/maven-publish.yml | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/.github/workflows/maven-publish.yml
b/.github/workflows/maven-publish.yml
index 780fdfa..304b251 100644
--- a/.github/workflows/maven-publish.yml
+++ b/.github/workflows/maven-publish.yml
@@ -29,10 +29,10 @@ jobs:
docker exec rmqbroker sh -c 'while ! nc -z localhost 10911; do sleep
1; done'
- uses: actions/checkout@v3
- - name: Set up JDK 11
+ - name: Set up JDK 1.8
uses: actions/setup-java@v3
with:
- java-version: '11'
+ java-version: '1.8'
distribution: 'temurin'
server-id: github # Value of the
distributionManagement/repository/id field of the pom.xml
settings-path: ${{ github.workspace }} # location for the
settings.xml file
