diff --git a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java index 0eef0098bd..ffa95c454f 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java @@ -56,7 +56,7 @@ import org.apache.rocketmq.broker.failover.EscapeBridge; import org.apache.rocketmq.broker.filter.CommitLogDispatcherCalcBitMap; import org.apache.rocketmq.broker.filter.ConsumerFilterManager; import org.apache.rocketmq.broker.filtersrv.FilterServerManager; -import org.apache.rocketmq.broker.hacontroller.ReplicasManager; +import org.apache.rocketmq.broker.controller.ReplicasManager; import org.apache.rocketmq.broker.latency.BrokerFastFailure; import org.apache.rocketmq.broker.latency.BrokerFixedThreadPoolExecutor; import org.apache.rocketmq.broker.loadbalance.AssignmentManager; diff --git a/broker/src/main/java/org/apache/rocketmq/broker/hacontroller/ReplicasManager.java b/broker/src/main/java/org/apache/rocketmq/broker/controller/ReplicasManager.java similarity index 99% rename from broker/src/main/java/org/apache/rocketmq/broker/hacontroller/ReplicasManager.java rename to broker/src/main/java/org/apache/rocketmq/broker/controller/ReplicasManager.java index d4ac86760b..34fc29acd6 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/hacontroller/ReplicasManager.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/controller/ReplicasManager.java @@ -15,7 +15,7 @@ * limitations under the License. */ -package org.apache.rocketmq.broker.hacontroller; +package org.apache.rocketmq.broker.controller; import java.util.ArrayList; import java.util.Arrays; diff --git a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java index 7f8b2a4375..fa316ba970 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java @@ -43,7 +43,7 @@ import org.apache.rocketmq.broker.client.ClientChannelInfo; import org.apache.rocketmq.broker.client.ConsumerGroupInfo; import org.apache.rocketmq.broker.filter.ConsumerFilterData; import org.apache.rocketmq.broker.filter.ExpressionMessageFilter; -import org.apache.rocketmq.broker.hacontroller.ReplicasManager; +import org.apache.rocketmq.broker.controller.ReplicasManager; import org.apache.rocketmq.broker.plugin.BrokerAttachedPlugin; import org.apache.rocketmq.broker.subscription.SubscriptionGroupManager; import org.apache.rocketmq.broker.transaction.queue.TransactionalMessageUtil; diff --git a/test/src/test/java/org/apache/rocketmq/test/autoswitchrole/AutoSwitchRoleIntegrationTest.java b/test/src/test/java/org/apache/rocketmq/test/autoswitchrole/AutoSwitchRoleIntegrationTest.java index e6a99a1ec9..99daa44307 100644 --- a/test/src/test/java/org/apache/rocketmq/test/autoswitchrole/AutoSwitchRoleIntegrationTest.java +++ b/test/src/test/java/org/apache/rocketmq/test/autoswitchrole/AutoSwitchRoleIntegrationTest.java @@ -19,7 +19,7 @@ package org.apache.rocketmq.test.autoswitchrole; import java.io.File; import org.apache.rocketmq.broker.BrokerController; -import org.apache.rocketmq.broker.hacontroller.ReplicasManager; +import org.apache.rocketmq.broker.controller.ReplicasManager; import org.apache.rocketmq.common.UtilAll; import org.apache.rocketmq.common.ControllerConfig; import org.apache.rocketmq.common.namesrv.NamesrvConfig;