public class AsyncClusterBinding extends AbstractReferenceCounted implements AsyncReadWriteBinding
Modifier and Type | Class and Description |
---|---|
private class |
AsyncClusterBinding.AsyncClusterBindingConnectionSource |
Modifier and Type | Field and Description |
---|---|
private Cluster |
cluster |
private ReadPreference |
readPreference |
Constructor and Description |
---|
AsyncClusterBinding(Cluster cluster,
ReadPreference readPreference)
Creates an instance.
|
Modifier and Type | Method and Description |
---|---|
private void |
getAsyncClusterBindingConnectionSource(ServerSelector serverSelector,
SingleResultCallback<AsyncConnectionSource> callback) |
void |
getReadConnectionSource(SingleResultCallback<AsyncConnectionSource> callback)
Returns a connection source to a server that satisfies the specified read preference.
|
ReadPreference |
getReadPreference()
The read preference that all connection sources returned by this instance will satisfy.
|
void |
getWriteConnectionSource(SingleResultCallback<AsyncConnectionSource> callback)
Supply a connection source to a server that can be written to
|
AsyncReadWriteBinding |
retain()
Retain an additional reference to this object.
|
getCount, release
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getCount, release
private final Cluster cluster
private final ReadPreference readPreference
public AsyncClusterBinding(Cluster cluster, ReadPreference readPreference)
cluster
- a non-null Cluster which will be used to select a server to bind toreadPreference
- a non-null ReadPreference for read operationspublic AsyncReadWriteBinding retain()
ReferenceCounted
retain
in interface AsyncReadBinding
retain
in interface AsyncReadWriteBinding
retain
in interface AsyncWriteBinding
retain
in interface ReferenceCounted
retain
in class AbstractReferenceCounted
public ReadPreference getReadPreference()
AsyncReadBinding
getReadPreference
in interface AsyncReadBinding
public void getReadConnectionSource(SingleResultCallback<AsyncConnectionSource> callback)
AsyncReadBinding
getReadConnectionSource
in interface AsyncReadBinding
callback
- the to be passed the connection sourcepublic void getWriteConnectionSource(SingleResultCallback<AsyncConnectionSource> callback)
AsyncWriteBinding
getWriteConnectionSource
in interface AsyncWriteBinding
callback
- the to be passed the connection sourceprivate void getAsyncClusterBindingConnectionSource(ServerSelector serverSelector, SingleResultCallback<AsyncConnectionSource> callback)