本文整理了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
暂无
代码示例来源: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;
内容来源于网络,如有侵权,请联系作者删除!