public class SingleServerBinding extends AbstractReferenceCounted implements ReadWriteBinding
Modifier and Type | Class and Description |
---|---|
private class |
SingleServerBinding.SingleServerBindingConnectionSource |
Modifier and Type | Field and Description |
---|---|
private Cluster |
cluster |
private ReadPreference |
readPreference |
private ServerAddress |
serverAddress |
Constructor and Description |
---|
SingleServerBinding(Cluster cluster,
ServerAddress serverAddress)
Creates an instance, defaulting to
ReadPreference.primary() for reads. |
SingleServerBinding(Cluster cluster,
ServerAddress serverAddress,
ReadPreference readPreference)
Creates an instance.
|
Modifier and Type | Method and Description |
---|---|
ConnectionSource |
getReadConnectionSource()
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.
|
ConnectionSource |
getWriteConnectionSource()
Supply a connection source to a server that can be written to
|
SingleServerBinding |
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 ServerAddress serverAddress
private final ReadPreference readPreference
public SingleServerBinding(Cluster cluster, ServerAddress serverAddress)
ReadPreference.primary()
for reads.cluster
- a non-null Cluster which will be used to select a server to bind toserverAddress
- a non-null address of the server to bind topublic SingleServerBinding(Cluster cluster, ServerAddress serverAddress, ReadPreference readPreference)
cluster
- a non-null Cluster which will be used to select a server to bind toserverAddress
- a non-null address of the server to bind toreadPreference
- a non-null ReadPreference for read operationspublic ConnectionSource getWriteConnectionSource()
WriteBinding
getWriteConnectionSource
in interface WriteBinding
public ReadPreference getReadPreference()
ReadBinding
getReadPreference
in interface ReadBinding
public ConnectionSource getReadConnectionSource()
ReadBinding
getReadConnectionSource
in interface ReadBinding
public SingleServerBinding retain()
ReferenceCounted
retain
in interface ReadBinding
retain
in interface ReadWriteBinding
retain
in interface ReferenceCounted
retain
in interface WriteBinding
retain
in class AbstractReferenceCounted