Package org.redisson.connection
Class ClientConnectionsEntry
-
- org.redisson.connection.ClientConnectionsEntry
-
public class ClientConnectionsEntry extends
- Author:
- Nikita Koksharov
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
ClientConnectionsEntry.FreezeReason
-
Constructor Summary
Constructors Constructor Description ClientConnectionsEntry(RedisClient client, int poolMinSize, int poolMaxSize, int subscribePoolMinSize, int subscribePoolMaxSize, ConnectionManager connectionManager, NodeType nodeType)
-
Method Summary
-
-
-
Constructor Detail
-
ClientConnectionsEntry
public ClientConnectionsEntry(RedisClient client, int poolMinSize, int poolMaxSize, int subscribePoolMinSize, int subscribePoolMaxSize, ConnectionManager connectionManager, NodeType nodeType)
-
-
Method Detail
-
isMasterForRead
public boolean isMasterForRead()
-
isInitialized
public boolean isInitialized()
-
setInitialized
public void setInitialized(boolean isInited)
-
setNodeType
public void setNodeType(NodeType nodeType)
-
getNodeType
public NodeType getNodeType()
-
resetFirstFail
public void resetFirstFail()
-
isFailed
public boolean isFailed()
-
trySetupFistFail
public void trySetupFistFail()
-
shutdownAsync
public > shutdownAsync()
-
getClient
public RedisClient getClient()
-
isFreezed
public boolean isFreezed()
-
setFreezeReason
public void setFreezeReason(ClientConnectionsEntry.FreezeReason freezeReason)
-
getFreezeReason
public ClientConnectionsEntry.FreezeReason getFreezeReason()
-
reset
public void reset()
-
getFreeAmount
public int getFreeAmount()
-
acquireConnection
public void acquireConnection( runnable, RedisCommand<?> command)
-
releaseConnection
public void releaseConnection()
-
pollConnection
public RedisConnection pollConnection(RedisCommand<?> command)
-
releaseConnection
public void releaseConnection(RedisConnection connection)
-
connect
public RFuture<RedisConnection> connect()
-
connectPubSub
public RFuture<RedisPubSubConnection> connectPubSub()
-
getAllConnections
public <RedisConnection> getAllConnections()
-
getAllSubscribeConnections
public <RedisPubSubConnection> getAllSubscribeConnections()
-
pollSubscribeConnection
public RedisPubSubConnection pollSubscribeConnection()
-
releaseSubscribeConnection
public void releaseSubscribeConnection(RedisPubSubConnection connection)
-
acquireSubscribeConnection
public void acquireSubscribeConnection( runnable)
-
releaseSubscribeConnection
public void releaseSubscribeConnection()
-
toString
public toString()
- Overrides:
in class
-
-