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

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

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

NioSocketAcceptor.dispose介绍

暂无

代码示例

代码示例来源:origin: apache/flume

@Override
public void stop() {
 logger.info("Stopping {}...", this);
 acceptor.unbind();
 acceptor.dispose();
 sourceCounter.stop();
 super.stop();
 logger.info("{} stopped. Metrics: {}", this, sourceCounter);
}

代码示例来源:origin: org.eclipse.neoscada.core/org.eclipse.scada.core.server.ngp

public void dispose ()
{
  this.acceptor.dispose ();
  this.chainBuilder.dispose ();
}

代码示例来源:origin: jobxhub/JobX

@Override
public void destroy() throws Throwable {
  try {
    if (acceptor != null) {
      acceptor.dispose();
    }
    this.serverDaemon.interrupt();
    if (logger.isInfoEnabled()) {
      logger.info("[JobX] MinaServer stoped!");
    }
  } catch (Throwable e) {
    if (logger.isErrorEnabled()) {
      logger.error("[JobX] MinaServer stop error:{}", stackTrace(e));
    }
  }
}

代码示例来源:origin: org.apache.flume/flume-ng-core

@Override
public void stop() {
 logger.info("Stopping {}...", this);
 acceptor.unbind();
 acceptor.dispose();
 sourceCounter.stop();
 super.stop();
 logger.info("{} stopped. Metrics: {}", this, sourceCounter);
}

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

public void stop() {
  synchronized (this) {
    if (!isRunning) {
      log.info("Server " + minaServerConfig.getName() + "is already stoped.");
      return;
    }
    isRunning = false;
    try {
      if (threadpool != null) {
        threadpool.shutdown();
      }
      acceptor.unbind();
      acceptor.dispose();
      log.info("Server is stoped.");
    } catch (Exception ex) {
      log.error("", ex);
    }
  }
}

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

public void stop() {
  synchronized (this) {
    if (!isRunning) {
      LOG.info("HttpServer " + minaServerConfig.getName() + "is already stoped.");
      return;
    }
    isRunning = false;
    try {
      if (threadpool != null) {
        threadpool.shutdown();
      }
      acceptor.unbind();
      acceptor.dispose();
      LOG.info("Server is stoped.");
    } catch (Exception ex) {
      LOG.error("", ex);
    }
  }
}

相关文章