Package org.redisson.connection.pool

Class PubSubConnectionPool

java.lang.Object

org.redisson.connection.pool.PubSubConnectionPool

Direct Known Subclasses:

MasterPubSubConnectionPool

public class PubSubConnectionPool
extends Object

Connection pool for Publish / Subscribe

Author:

Nikita Koksharov

Field Summary

Fields

Modifier and Type	Field	Description
protected final Queue<ClientConnectionsEntry>	entries

Constructor Summary

Constructors

Constructor	Description
PubSubConnectionPool(MasterSlaveServersConfig config, ConnectionManager connectionManager, MasterSlaveEntry masterSlaveEntry)

Method Summary

Modifier and Type	Method	Description
protected final CompletableFuture<RedisPubSubConnection>	acquireConnection(RedisCommand<?> command, ClientConnectionsEntry entry)
final void	addEntry(ClientConnectionsEntry entry)
CompletableFuture<RedisPubSubConnection>	get()
CompletableFuture<RedisPubSubConnection>	get(RedisCommand<?> command)
CompletableFuture<RedisPubSubConnection>	get(RedisCommand<?> command, ClientConnectionsEntry entry)
CompletableFuture<RedisPubSubConnection>	get(ClientConnectionsEntry entry)
protected ConnectionsHolder<RedisPubSubConnection>	getConnectionHolder(ClientConnectionsEntry entry)
final void	returnConnection(ClientConnectionsEntry entry, RedisPubSubConnection connection)

Methods inherited from class java.lang.Object

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

Field Details

entries

protected final Queue<ClientConnectionsEntry> entries

Constructor Details

PubSubConnectionPool

public PubSubConnectionPool(MasterSlaveServersConfig config,
 ConnectionManager connectionManager,
 MasterSlaveEntry masterSlaveEntry)

Method Details

get

public CompletableFuture<RedisPubSubConnection> get()

get

public CompletableFuture<RedisPubSubConnection> get(ClientConnectionsEntry entry)

getConnectionHolder

protected ConnectionsHolder<RedisPubSubConnection> getConnectionHolder(ClientConnectionsEntry entry)

addEntry

public final void addEntry(ClientConnectionsEntry entry)

get

public CompletableFuture<RedisPubSubConnection> get(RedisCommand<?> command)

get

public CompletableFuture<RedisPubSubConnection> get(RedisCommand<?> command,
 ClientConnectionsEntry entry)

acquireConnection

protected final CompletableFuture<RedisPubSubConnection> acquireConnection(RedisCommand<?> command,
 ClientConnectionsEntry entry)

returnConnection

public final void returnConnection(ClientConnectionsEntry entry,
 RedisPubSubConnection connection)