diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/processor/DefaultMessagingProcessor.java b/proxy/src/main/java/org/apache/rocketmq/proxy/processor/DefaultMessagingProcessor.java
index 885b5d311b..0269b752be 100644
--- a/proxy/src/main/java/org/apache/rocketmq/proxy/processor/DefaultMessagingProcessor.java
+++ b/proxy/src/main/java/org/apache/rocketmq/proxy/processor/DefaultMessagingProcessor.java
@@ -217,7 +217,7 @@ public class DefaultMessagingProcessor extends AbstractStartAndShutdown implemen
 
     @Override
     public ProxyRelayService getProxyOutService() {
-        return this.serviceManager.getProxyOutService();
+        return this.serviceManager.getProxyRelayService();
     }
 
 }
diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/service/ClusterServiceManager.java b/proxy/src/main/java/org/apache/rocketmq/proxy/service/ClusterServiceManager.java
index 1fda36c9f3..de6eda54a2 100644
--- a/proxy/src/main/java/org/apache/rocketmq/proxy/service/ClusterServiceManager.java
+++ b/proxy/src/main/java/org/apache/rocketmq/proxy/service/ClusterServiceManager.java
@@ -122,7 +122,7 @@ public class ClusterServiceManager extends AbstractStartAndShutdown implements S
     }
 
     @Override
-    public ProxyRelayService getProxyOutService() {
+    public ProxyRelayService getProxyRelayService() {
         return this.proxyRelayService;
     }
 
diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/service/LocalServiceManager.java b/proxy/src/main/java/org/apache/rocketmq/proxy/service/LocalServiceManager.java
index c2438c939c..36a798d273 100644
--- a/proxy/src/main/java/org/apache/rocketmq/proxy/service/LocalServiceManager.java
+++ b/proxy/src/main/java/org/apache/rocketmq/proxy/service/LocalServiceManager.java
@@ -78,7 +78,7 @@ public class LocalServiceManager extends AbstractStartAndShutdown implements Ser
     }
 
     @Override
-    public ProxyRelayService getProxyOutService() {
+    public ProxyRelayService getProxyRelayService() {
         return this.proxyRelayService;
     }
 
diff --git a/proxy/src/main/java/org/apache/rocketmq/proxy/service/ServiceManager.java b/proxy/src/main/java/org/apache/rocketmq/proxy/service/ServiceManager.java
index a51a1a1307..c80811f469 100644
--- a/proxy/src/main/java/org/apache/rocketmq/proxy/service/ServiceManager.java
+++ b/proxy/src/main/java/org/apache/rocketmq/proxy/service/ServiceManager.java
@@ -35,5 +35,5 @@ public interface ServiceManager extends StartAndShutdown {
 
     TransactionService getTransactionService();
 
-    ProxyRelayService getProxyOutService();
+    ProxyRelayService getProxyRelayService();
 }
diff --git a/proxy/src/test/java/org/apache/rocketmq/proxy/processor/BaseProcessorTest.java b/proxy/src/test/java/org/apache/rocketmq/proxy/processor/BaseProcessorTest.java
index 29e0ab3379..31954705b7 100644
--- a/proxy/src/test/java/org/apache/rocketmq/proxy/processor/BaseProcessorTest.java
+++ b/proxy/src/test/java/org/apache/rocketmq/proxy/processor/BaseProcessorTest.java
@@ -78,7 +78,7 @@ public class BaseProcessorTest extends InitConfigAndLoggerTest {
         when(serviceManager.getProducerManager()).thenReturn(producerManager);
         when(serviceManager.getConsumerManager()).thenReturn(consumerManager);
         when(serviceManager.getTransactionService()).thenReturn(transactionService);
-        when(serviceManager.getProxyOutService()).thenReturn(proxyRelayService);
+        when(serviceManager.getProxyRelayService()).thenReturn(proxyRelayService);
     }
 
     protected static ProxyContext createContext() {