模块 org.redkale

程序包 org.redkale.net

类 Transport.TransportNode

java.lang.Object

org.redkale.net.Transport.TransportNode

封闭类:

Transport

public static class Transport.TransportNode
extends Object

字段概要

字段

修饰符和类型	字段	说明
protected InetSocketAddress	address
protected ConcurrentHashMap<String,Object>	attributes
protected BlockingQueue<AsyncConnection>	connQueue
protected long	disabletime
protected ArrayBlockingQueue<CompletableFuture<AsyncConnection>>	pollQueue

构造器概要

构造器

构造器	说明
TransportNode(int poolMaxConns, InetSocketAddress address)
TransportNode(int poolMaxConns, InetSocketAddress address, long disabletime)

方法概要

修饰符和类型	方法	说明
Transport.TransportNode	clearAttributes()
void	dispose()
boolean	equals(Object obj)
InetSocketAddress	getAddress()
<T> T	getAttribute(String name)
ConcurrentHashMap<String,Object>	getAttributes()
BlockingQueue<AsyncConnection>	getConnQueue()
long	getDisabletime()
int	getPoolMaxConns()
int	hashCode()
<T> T	removeAttribute(String name)
<T> T	setAttribute(String name, T value)
void	setAttributes(ConcurrentHashMap<String,Object> map)
String	toString()

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

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

字段详细资料

address

protected InetSocketAddress address

disabletime

protected volatile long disabletime

connQueue

protected final BlockingQueue<AsyncConnection> connQueue

pollQueue

protected final ArrayBlockingQueue<CompletableFuture<AsyncConnection>> pollQueue

attributes

protected final ConcurrentHashMap<String,Object> attributes

构造器详细资料

TransportNode

public TransportNode(int poolMaxConns,
                     InetSocketAddress address)

TransportNode

@ConstructorParameters({"poolMaxConns","address","disabletime"})
public TransportNode(int poolMaxConns,
                     InetSocketAddress address,
                     long disabletime)

方法详细资料

getPoolMaxConns

public int getPoolMaxConns()

setAttribute

public <T> T setAttribute(String name,
                          T value)

getAttribute

public <T> T getAttribute(String name)

removeAttribute

public <T> T removeAttribute(String name)

clearAttributes

public Transport.TransportNode clearAttributes()

getAttributes

public ConcurrentHashMap<String,Object> getAttributes()

setAttributes

public void setAttributes(ConcurrentHashMap<String,Object> map)

getAddress

public InetSocketAddress getAddress()

getDisabletime

public long getDisabletime()

getConnQueue

public BlockingQueue<AsyncConnection> getConnQueue()

dispose

public void dispose()

hashCode

public int hashCode()

覆盖:

hashCode 在类中 Object

equals

public boolean equals(Object obj)

覆盖:

equals 在类中 Object

toString

public String toString()

覆盖:

toString 在类中 Object