@Test public void testDoStart() throws Exception { session.endpoint = new DefaultProxyEndpoint("TCP: session.setSessionState(new SessionEstablished(session)); session.doStart(); verify(selector, never()).getCandidates(); }
@Override protected void doStart() throws Exception { super.doStart(); connect(); }
DefaultBackendSession extends AbstractSession implements BackendSession { @Override protected void doStart() throws Exception { super.doStart(); connect(); } }
DefaultBackendSession extends AbstractSession implements BackendSession { @Override protected void doStart() throws Exception { super.doStart(); connect(); } DefaultBackendSession(Tunnel tunnel, EventLoopGroup eventLoopGroup, long trafficReportIntervalMillis,
                                 ResourceManager resourceManager); }
DefaultBackendSession extends AbstractSession implements BackendSession { @Override protected void doStart() throws Exception { super.doStart(); connect(); } DefaultBackendSession(Tunnel tunnel, EventLoopGroup eventLoopGroup, long trafficReportIntervalMillis,
                                 ResourceManager resourceManager); @Override void sendAfterProtocol(ByteBuf byteBuf); @Override SESSION_TYPE getSessionType(); SessionState getSessionState(); @Override SessionMonitor getSessionMonitor(); }
DefaultBackendSession extends AbstractSession implements BackendSession { @Override protected void doStart() throws Exception { super.doStart(); connect(); } DefaultBackendSession(Tunnel tunnel, EventLoopGroup eventLoopGroup, long trafficReportIntervalMillis,
                                 ResourceManager resourceManager); @Override void sendAfterProtocol(ByteBuf byteBuf); @Override SESSION_TYPE getSessionType(); SessionState getSessionState(); @Override SessionMonitor getSessionMonitor();  }