程序包 com.iohao.game.bolt.broker.client.processor.connection

类 ConnectEventClientProcessor

java.lang.Object

com.iohao.game.bolt.broker.client.processor.connection.ConnectEventClientProcessor

所有已实现的接口:

com.alipay.remoting.ConnectionEventProcessor, BrokerClientItemAware

public class ConnectEventClientProcessor
extends Object
implements com.alipay.remoting.ConnectionEventProcessor, BrokerClientItemAware

作者:

渔民小镇

日期:

2022-05-14

构造器概要

构造器

构造器	说明
ConnectEventClientProcessor()

方法概要

修饰符和类型	方法	说明
com.alipay.remoting.Connection	getConnection()
int	getConnectTimes()
String	getRemoteAddress()
boolean	isConnected()
void	onEvent(String remoteAddress, com.alipay.remoting.Connection conn)
void	reset()

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 com.iohao.game.bolt.broker.core.aware.BrokerClientItemAware

setBrokerClientItem

构造器详细资料

ConnectEventClientProcessor

public ConnectEventClientProcessor()

方法详细资料

onEvent

public void onEvent(String remoteAddress,
 com.alipay.remoting.Connection conn)

指定者:

onEvent 在接口中 com.alipay.remoting.ConnectionEventProcessor

isConnected

public boolean isConnected()
                    throws InterruptedException

抛出:

InterruptedException

getConnectTimes

public int getConnectTimes()
                    throws InterruptedException

抛出:

InterruptedException

getConnection

public com.alipay.remoting.Connection getConnection()
                                             throws InterruptedException

抛出:

InterruptedException

getRemoteAddress

public String getRemoteAddress()
                        throws InterruptedException

抛出:

InterruptedException

reset

public void reset()