Commit 200b89e1 authored by zengtianlai3's avatar zengtianlai3

update

parent 788836b5
Pipeline #285 failed with stages
...@@ -98,8 +98,8 @@ public class ForwardClientHandler extends SimpleChannelInboundHandler<Object> { ...@@ -98,8 +98,8 @@ public class ForwardClientHandler extends SimpleChannelInboundHandler<Object> {
int port = socketAddr.getPort(); int port = socketAddr.getPort();
log.debug("client disconnected--->,ip:" + clientIp + ",port:" + port); log.debug("client disconnected--->,ip:" + clientIp + ",port:" + port);
ctx.close(); ctx.close();
ForwardManager forwardManager = SpringUtil.getBean(ForwardManager.class); // ForwardManager forwardManager = SpringUtil.getBean(ForwardManager.class);
forwardManager.startTcpClient(); // forwardManager.startTcpClient();
} }
@Override @Override
......
...@@ -15,6 +15,7 @@ public class ForwardConnectionListener extends BaseConnectionListener { ...@@ -15,6 +15,7 @@ public class ForwardConnectionListener extends BaseConnectionListener {
@Override @Override
public void operationComplete(ChannelFuture channelFuture) throws Exception { public void operationComplete(ChannelFuture channelFuture) throws Exception {
log.debug("listen ..."+appId);
if (!channelFuture.isSuccess()) { if (!channelFuture.isSuccess()) {
final EventLoop loop = channelFuture.channel().eventLoop(); final EventLoop loop = channelFuture.channel().eventLoop();
loop.schedule(new Runnable() { loop.schedule(new Runnable() {
...@@ -25,7 +26,7 @@ public class ForwardConnectionListener extends BaseConnectionListener { ...@@ -25,7 +26,7 @@ public class ForwardConnectionListener extends BaseConnectionListener {
log.debug("channelActive.forwardManager:" + forwardManager); log.debug("channelActive.forwardManager:" + forwardManager);
log.warn("The client is not connected and starts to reconnect..." + forwardManager); log.warn("The client is not connected and starts to reconnect..." + forwardManager);
forwardManager.startTcpClient(); forwardManager.startTcpClient(appId);
} }
}, 10L, TimeUnit.SECONDS); }, 10L, TimeUnit.SECONDS);
} else { } else {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment