mirror of
https://github.com/apache/rocketmq.git
synced 2026-09-24 16:04:00 +08:00
[ISSUE #3949] improve readability.
This commit is contained in:
+1
-1
@@ -217,7 +217,7 @@ public class DefaultMessagingProcessor extends AbstractStartAndShutdown implemen
|
||||
|
||||
@Override
|
||||
public ProxyRelayService getProxyOutService() {
|
||||
return this.serviceManager.getProxyOutService();
|
||||
return this.serviceManager.getProxyRelayService();
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -122,7 +122,7 @@ public class ClusterServiceManager extends AbstractStartAndShutdown implements S
|
||||
}
|
||||
|
||||
@Override
|
||||
public ProxyRelayService getProxyOutService() {
|
||||
public ProxyRelayService getProxyRelayService() {
|
||||
return this.proxyRelayService;
|
||||
}
|
||||
|
||||
|
||||
@@ -78,7 +78,7 @@ public class LocalServiceManager extends AbstractStartAndShutdown implements Ser
|
||||
}
|
||||
|
||||
@Override
|
||||
public ProxyRelayService getProxyOutService() {
|
||||
public ProxyRelayService getProxyRelayService() {
|
||||
return this.proxyRelayService;
|
||||
}
|
||||
|
||||
|
||||
@@ -35,5 +35,5 @@ public interface ServiceManager extends StartAndShutdown {
|
||||
|
||||
TransactionService getTransactionService();
|
||||
|
||||
ProxyRelayService getProxyOutService();
|
||||
ProxyRelayService getProxyRelayService();
|
||||
}
|
||||
|
||||
@@ -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() {
|
||||
|
||||
Reference in New Issue
Block a user