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 <[email protected]> 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();
