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