org.apache.mina.transport.socket.nio.NioSocketConnector.dispose()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(3.4k)|赞(0)|评价(0)|浏览(97)

本文整理了Java中org.apache.mina.transport.socket.nio.NioSocketConnector.dispose()方法的一些代码示例,展示了NioSocketConnector.dispose()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。NioSocketConnector.dispose()方法的具体详情如下:
包路径:org.apache.mina.transport.socket.nio.NioSocketConnector
类名称:NioSocketConnector
方法名:dispose

NioSocketConnector.dispose介绍

暂无

代码示例

代码示例来源:origin: ltsopensource/light-task-scheduler

@Override
protected void clientShutdown() {
  if (connector != null) {
    connector.dispose();
  }
}

代码示例来源:origin: ltsopensource/light-task-scheduler

@Override
protected void clientShutdown() {
  if (connector != null) {
    connector.dispose();
  }
}

代码示例来源:origin: com.github.ltsopensource/lts-core

@Override
protected void clientShutdown() {
  if (connector != null) {
    connector.dispose();
  }
}

代码示例来源:origin: OpenNMS/opennms

@Override
  protected void dispose() {
    synchronized (m_connectorMutex) {
      m_connector.dispose();
    }
  }
}

代码示例来源:origin: cuihp/AndroidServer

/**
 * 断开连接
 */
public void disConnect() {
  mConnection.dispose();
  mConnection = null;
  mAddress = null;
  mSession = null;
}

代码示例来源:origin: jzyong/game-server

public void stop() {
  synchronized (this) {
    try {
      connector.dispose();
      log.info("Client is stoped.");
    } catch (Exception ex) {
      log.error("", ex);
    }
  }
}

代码示例来源:origin: com.github.mrstampy/esp

/**
 * Disconnects from the {@link AbstractMultiConnectionSocket} instance.
 */
public void disconnect() {
  if (!isConnected()) {
    log.debug("Already disconnected");
    return;
  }
  connector.dispose(true);
  connector = null;
  log.info("Disconnected from AbstractMultiConnectionSocket on host {} and port {}", socketBroadcasterHost,
      BROADCASTER_PORT);
}

代码示例来源:origin: de.dentrassi.eclipse.neoscada.core/org.eclipse.scada.da.server.common.io

protected void performDispose ()
{
  disconnect ();
  this.stateItem.updateData ( Variant.valueOf ( "DISPOSED" ), null, null );
  if ( this.connector != null )
  {
    this.connector.dispose ();
    this.connector = null;
  }
  this.itemFactory.dispose ();
  if ( this.createdExecutor != null )
  {
    this.createdExecutor.shutdown ();
  }
}

代码示例来源:origin: com.github.mrstampy/esp

/**
 * Connects to the {@link AbstractMultiConnectionSocket} instance. The
 * listeners will not be notified of events until
 * {@link #subscribe(EventType...)} or {@link #subscribeAll()} has been
 * called.
 * 
 * @throws MultiConnectionSocketException
 *           if unable to connect to a {@link AbstractMultiConnectionSocket}
 */
public void connect() throws MultiConnectionSocketException {
  if (isConnected()) {
    log.error("Already connected");
    return;
  }
  initConnector();
  ConnectFuture cf = connector.connect(new InetSocketAddress(socketBroadcasterHost, BROADCASTER_PORT));
  cf.awaitUninterruptibly(2000);
  if (cf.isConnected()) {
    log.info("Connected to AbstractMultiConnectionSocket on host {} and port {}", socketBroadcasterHost,
        BROADCASTER_PORT);
  } else {
    connector.dispose(true);
    String msg = format("Could not connect to AbstractMultiConnectionSocket on host {0} and port {1}",
        socketBroadcasterHost, BROADCASTER_PORT);
    log.error(msg);
    throw new MultiConnectionSocketException(msg);
  }
}

代码示例来源:origin: r17171709/android_demo

/**
 * 关闭
 */
public void close() {
  if(ioSession!=null && ioSession.isConnected()){
    ioSession.close(false);
  }
  if(connectFuture!=null && connectFuture.isConnected()) {
    connectFuture.cancel();
  }
  if(connector!=null && !connector.isDisposed()) {
    connector.dispose();
  }
}

代码示例来源:origin: OpenNMS/opennms

} catch (Throwable e) {
  LOG.debug("Caught exception on factory {}, retrying: {}", this, e);
  m_connector.dispose();
  m_connector = getSocketConnector(getTimeout(), handler);
  continue;

相关文章