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

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

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

NioSocketAcceptor.unbind介绍

暂无

代码示例

代码示例来源:origin: igniterealtime/Openfire

/**
 * Stops this acceptor by unbinding the socket acceptor. Does nothing when the instance is not started.
 */
@Override
public synchronized void stop()
{
  if ( socketAcceptor != null )
  {
    socketAcceptor.unbind();
    socketAcceptor = null;
  }
}

代码示例来源: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: igniterealtime/Openfire

socketAcceptor.unbind();
} finally {
  socketAcceptor = null;

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

public void stop ()
{
  this.acceptor.unbind ();
}

代码示例来源:origin: org.igniterealtime.openfire/xmppserver

/**
 * Stops this acceptor by unbinding the socket acceptor. Does nothing when the instance is not started.
 */
@Override
public synchronized void stop()
{
  if ( socketAcceptor != null )
  {
    socketAcceptor.unbind();
    socketAcceptor = null;
  }
}

代码示例来源:origin: com.bbossgroups.rpc/bboss-rpc

public void stop()
{
  if(!this.started)
    return;
  log.debug("Stop mina server [" + acceptor.getLocalAddress() + "] begin.");
  if(acceptor == null)
    return;
  acceptor.unbind();
  this.started = false;
  log.debug("Stop mina server [" + acceptor.getLocalAddress() + "] end.");
}

代码示例来源: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: com.github.mrstampy/esp

@Override
public void unbindBroadcaster() {
  if (!canBroadcast()) {
    log.warn("AbstractMultiConnectionSocket is not broadcasting events, cannot unbind broadcaster");
    return;
  }
  if (!socketBroadcaster.isActive()) {
    log.warn("AbstractMultiConnectionSocket is already unbound");
    return;
  }
  socketBroadcaster.unbind();
  notifyConnectionEventListeners(State.UNBOUND);
}

代码示例来源: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);
    }
  }
}

代码示例来源:origin: org.igniterealtime.openfire/xmppserver

socketAcceptor.unbind();
} finally {
  socketAcceptor = null;

相关文章