You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by yu...@apache.org on 2019/06/28 11:19:48 UTC
[rocketmq-remoting] 13/39: Adjust the position of Remoting factory
This is an automated email from the ASF dual-hosted git repository.
yukon pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-remoting.git
commit 85cee3ca6ad2c84036d93aeb643b144f6d5efbe9
Author: yukon <yu...@apache.org>
AuthorDate: Fri May 17 16:40:18 2019 +0800
Adjust the position of Remoting factory
---
.../java/org/apache/rocketmq/remoting/RemotingBootstrapFactory.java | 4 +++-
.../org/apache/rocketmq/remoting/impl/netty/NettyRemotingClient.java | 2 +-
.../org/apache/rocketmq/remoting/impl/netty/NettyRemotingServer.java | 2 +-
3 files changed, 5 insertions(+), 3 deletions(-)
diff --git a/remoting-core/remoting-impl/src/main/java/org/apache/rocketmq/remoting/RemotingBootstrapFactory.java b/remoting-core/remoting-impl/src/main/java/org/apache/rocketmq/remoting/RemotingBootstrapFactory.java
index 4dd502c..efa4078 100644
--- a/remoting-core/remoting-impl/src/main/java/org/apache/rocketmq/remoting/RemotingBootstrapFactory.java
+++ b/remoting-core/remoting-impl/src/main/java/org/apache/rocketmq/remoting/RemotingBootstrapFactory.java
@@ -15,11 +15,13 @@
* limitations under the License.
*/
-package org.apache.rocketmq.remoting.impl.netty;
+package org.apache.rocketmq.remoting;
import java.util.Properties;
import org.apache.rocketmq.remoting.api.RemotingClient;
import org.apache.rocketmq.remoting.config.RemotingConfig;
+import org.apache.rocketmq.remoting.impl.netty.NettyRemotingClient;
+import org.apache.rocketmq.remoting.impl.netty.NettyRemotingServer;
import org.apache.rocketmq.remoting.internal.BeanUtils;
import org.apache.rocketmq.remoting.internal.PropertyUtils;
import org.jetbrains.annotations.NotNull;
diff --git a/remoting-core/remoting-impl/src/main/java/org/apache/rocketmq/remoting/impl/netty/NettyRemotingClient.java b/remoting-core/remoting-impl/src/main/java/org/apache/rocketmq/remoting/impl/netty/NettyRemotingClient.java
index 44788c3..c263f22 100644
--- a/remoting-core/remoting-impl/src/main/java/org/apache/rocketmq/remoting/impl/netty/NettyRemotingClient.java
+++ b/remoting-core/remoting-impl/src/main/java/org/apache/rocketmq/remoting/impl/netty/NettyRemotingClient.java
@@ -70,7 +70,7 @@ public class NettyRemotingClient extends NettyRemotingAbstract implements Remoti
private final Lock lockChannelTables = new ReentrantLock();
private EventExecutorGroup workerGroup;
- NettyRemotingClient(final RemotingConfig clientConfig) {
+ public NettyRemotingClient(final RemotingConfig clientConfig) {
super(clientConfig);
this.clientConfig = clientConfig;
diff --git a/remoting-core/remoting-impl/src/main/java/org/apache/rocketmq/remoting/impl/netty/NettyRemotingServer.java b/remoting-core/remoting-impl/src/main/java/org/apache/rocketmq/remoting/impl/netty/NettyRemotingServer.java
index 6b763cf..0d06336 100644
--- a/remoting-core/remoting-impl/src/main/java/org/apache/rocketmq/remoting/impl/netty/NettyRemotingServer.java
+++ b/remoting-core/remoting-impl/src/main/java/org/apache/rocketmq/remoting/impl/netty/NettyRemotingServer.java
@@ -66,7 +66,7 @@ public class NettyRemotingServer extends NettyRemotingAbstract implements Remoti
private int port;
- NettyRemotingServer(final RemotingConfig serverConfig) {
+ public NettyRemotingServer(final RemotingConfig serverConfig) {
super(serverConfig);
this.serverBootstrap = new ServerBootstrap();