mirror of
https://github.com/apache/rocketmq.git
synced 2026-09-01 15:47:01 +08:00
Change flow_control config name
This commit is contained in:
@@ -38,7 +38,7 @@ public class FlowControlConfig {
|
||||
|
||||
private String flowControlFileHome = System.getProperty(MixAll.ROCKETMQ_HOME_PROPERTY, System.getenv(MixAll.ROCKETMQ_HOME_ENV));
|
||||
|
||||
private static final String DEFAULT_FLOW_CONTROL_FILE = "conf/flowControl.yml";
|
||||
private static final String DEFAULT_FLOW_CONTROL_FILE = "conf/flow_control.yml";
|
||||
|
||||
private String flowControlFileName = System.getProperty("rocketmq.flow.control.file", DEFAULT_FLOW_CONTROL_FILE);
|
||||
|
||||
|
||||
@@ -46,6 +46,10 @@
|
||||
<groupId>org.apache.rocketmq</groupId>
|
||||
<artifactId>rocketmq-example</artifactId>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.apache.rocketmq</groupId>
|
||||
<artifactId>rocketmq-snode</artifactId>
|
||||
</dependency>
|
||||
</dependencies>
|
||||
|
||||
<build>
|
||||
|
||||
@@ -67,6 +67,7 @@
|
||||
<include>org.apache.rocketmq:rocketmq-namesrv</include>
|
||||
<include>org.apache.rocketmq:rocketmq-example</include>
|
||||
<include>org.apache.rocketmq:rocketmq-openmessaging</include>
|
||||
<include>org.apache.rocketmq:rocketmq-snode</include>
|
||||
</includes>
|
||||
<binaries>
|
||||
<outputDirectory>lib/</outputDirectory>
|
||||
|
||||
@@ -530,6 +530,11 @@
|
||||
<artifactId>rocketmq-acl</artifactId>
|
||||
<version>${project.version}</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>${project.groupId}</groupId>
|
||||
<artifactId>rocketmq-snode</artifactId>
|
||||
<version>${project.version}</version>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.slf4j</groupId>
|
||||
<artifactId>slf4j-api</artifactId>
|
||||
|
||||
@@ -41,7 +41,7 @@ public class SnodeControllerTest {
|
||||
@Test
|
||||
public void testSnodeRestartWithAclEnable() {
|
||||
System.setProperty("rocketmq.home.dir", "src/test/resources");
|
||||
System.setProperty("rocketmq.flow.control.file", "/conf/flowControl.yml");
|
||||
System.setProperty("rocketmq.acl.plain.file", "/conf/plain_acl.yml");
|
||||
SnodeConfig snodeConfig = new SnodeConfig();
|
||||
snodeConfig.setAclEnable(true);
|
||||
SnodeController snodeController = new SnodeController(
|
||||
|
||||
Reference in New Issue
Block a user