This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch runtimer
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
The following commit(s) were added to refs/heads/runtimer by this push:
new ba4b00b feat:add ConfigModeEnum(File/DB/CONTROLLER)
ba4b00b is described below
commit ba4b00b1a6fd9dfd55803dd717df5eed25502a3d
Author: 2011shenlin <[email protected]>
AuthorDate: Sun Apr 9 15:34:48 2023 +0800
feat:add ConfigModeEnum(File/DB/CONTROLLER)
---
.../eventbridge/adapter/runtimer/Runtimer.java | 22 ++++++++----
.../runtimer/common/enums/ConfigModeEnum.java | 39 ++++++++++++++++++++++
.../service/TargetRunnerConfigOnDBObserver.java | 4 +--
3 files changed, 55 insertions(+), 10 deletions(-)
diff --git
a/adapter/runtimer/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtimer/Runtimer.java
b/adapter/runtimer/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtimer/Runtimer.java
index 399fba9..7eb922d 100644
---
a/adapter/runtimer/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtimer/Runtimer.java
+++
b/adapter/runtimer/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtimer/Runtimer.java
@@ -17,23 +17,24 @@
package org.apache.rocketmq.eventbridge.adapter.runtimer;
+import java.util.concurrent.atomic.AtomicReference;
+import javax.annotation.PostConstruct;
import org.apache.rocketmq.eventbridge.adapter.runtimer.boot.EventBusListener;
import org.apache.rocketmq.eventbridge.adapter.runtimer.boot.EventRuleTransfer;
import org.apache.rocketmq.eventbridge.adapter.runtimer.boot.EventTargetPusher;
-import
org.apache.rocketmq.eventbridge.adapter.runtimer.boot.listener.EventSubscriber;
import
org.apache.rocketmq.eventbridge.adapter.runtimer.boot.listener.CirculatorContext;
+import
org.apache.rocketmq.eventbridge.adapter.runtimer.boot.listener.EventSubscriber;
import
org.apache.rocketmq.eventbridge.adapter.runtimer.boot.listener.RocketMQEventSubscriber;
import org.apache.rocketmq.eventbridge.adapter.runtimer.common.RuntimerState;
-import
org.apache.rocketmq.eventbridge.adapter.runtimer.service.AbstractTargetRunnerConfigObserver;
+import
org.apache.rocketmq.eventbridge.adapter.runtimer.common.enums.ConfigModeEnum;
import
org.apache.rocketmq.eventbridge.adapter.runtimer.service.TargetRunnerConfigObserver;
+import
org.apache.rocketmq.eventbridge.adapter.runtimer.service.TargetRunnerConfigOnDBObserver;
import
org.apache.rocketmq.eventbridge.adapter.runtimer.service.TargetRunnerConfigOnFileObserver;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
-import javax.annotation.PostConstruct;
-import java.util.concurrent.atomic.AtomicReference;
-
/**
* event bridge runtimer
*
@@ -50,9 +51,16 @@ public class Runtimer {
private TargetRunnerConfigObserver runnerConfigObserver;
- public Runtimer(CirculatorContext circulatorContext) {
+ public Runtimer(CirculatorContext circulatorContext,
@Value("${rumtimer.config.mode}") String configMode) {
this.circulatorContext = circulatorContext;
- this.runnerConfigObserver = new TargetRunnerConfigOnFileObserver();
+ switch (ConfigModeEnum.parse(configMode)) {
+ case DB:
+ this.runnerConfigObserver = new
TargetRunnerConfigOnDBObserver();
+ break;
+ default:
+ this.runnerConfigObserver = new
TargetRunnerConfigOnFileObserver();
+ break;
+ }
}
@PostConstruct
diff --git
a/adapter/runtimer/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtimer/common/enums/ConfigModeEnum.java
b/adapter/runtimer/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtimer/common/enums/ConfigModeEnum.java
new file mode 100644
index 0000000..f925ed3
--- /dev/null
+++
b/adapter/runtimer/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtimer/common/enums/ConfigModeEnum.java
@@ -0,0 +1,39 @@
+/*
+ * 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.adapter.runtimer.common.enums;
+
+import com.google.common.base.Strings;
+
+public enum ConfigModeEnum {
+ FILE,
+ DB,
+ CONTROLLER;
+
+ public static ConfigModeEnum parse(String code) {
+ if (Strings.isNullOrEmpty(code)) {
+ return FILE;
+ }
+ for (ConfigModeEnum configModeEnum : ConfigModeEnum.values()) {
+ if (configModeEnum.name().equals(code)) {
+ return configModeEnum;
+ }
+ }
+ return FILE;
+ }
+}
\ No newline at end of file
diff --git
a/adapter/runtimer/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtimer/service/TargetRunnerConfigOnDBObserver.java
b/adapter/runtimer/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtimer/service/TargetRunnerConfigOnDBObserver.java
index 3d847a1..1841e3c 100644
---
a/adapter/runtimer/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtimer/service/TargetRunnerConfigOnDBObserver.java
+++
b/adapter/runtimer/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtimer/service/TargetRunnerConfigOnDBObserver.java
@@ -24,7 +24,6 @@ import java.util.concurrent.TimeUnit;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.common.utils.ThreadUtils;
import
org.apache.rocketmq.eventbridge.adapter.runtimer.common.entity.TargetRunnerConfig;
-import org.apache.rocketmq.eventbridge.adapter.runtimer.common.plugin.Plugin;
@Slf4j
public class TargetRunnerConfigOnDBObserver extends
AbstractTargetRunnerConfigObserver {
@@ -32,8 +31,7 @@ public class TargetRunnerConfigOnDBObserver extends
AbstractTargetRunnerConfigOb
private static ScheduledExecutorService service =
Executors.newSingleThreadScheduledExecutor(
ThreadUtils.newThreadFactory("TargetRunnerConfigOnDBObserver", false));
- public TargetRunnerConfigOnDBObserver(Plugin plugin) {
- this.addListen(this);
+ public TargetRunnerConfigOnDBObserver() {
}
@Override
