From 418ced880e86ef1c8860695a1bf7b5cd8c6a0bec Mon Sep 17 00:00:00 2001
From: "Jixiang.jjx" <jixiang.jjx@alibaba-inc.com>
Date: Tue, 17 May 2022 19:00:51 +0800
Subject: [PATCH]  [ISSUE #3949] improve readability.

---
 .../rocketmq/proxy/processor/DefaultMessagingProcessor.java     | 2 +-
 .../apache/rocketmq/proxy/service/ClusterServiceManager.java    | 2 +-
 .../org/apache/rocketmq/proxy/service/LocalServiceManager.java  | 2 +-
 .../java/org/apache/rocketmq/proxy/service/ServiceManager.java  | 2 +-
 .../org/apache/rocketmq/proxy/processor/BaseProcessorTest.java  | 2 +-
 5 files changed, 5 insertions(+), 5 deletions(-)

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() {