Package com.mongodb.binding

Class ClusterBinding

java.lang.Object

com.mongodb.binding.ClusterBinding

All Implemented Interfaces:

ReadBinding, ReadWriteBinding, ReferenceCounted, WriteBinding

public class ClusterBinding
extends Object
implements ReadWriteBinding

A simple ReadWriteBinding implementation that supplies write connection sources bound to a possibly different primary each time, and a read connection source bound to a possible different server each time.

Since:

3.0

Constructor Summary

Constructors

Constructor	Description
ClusterBinding(Cluster cluster, ReadPreference readPreference)	Creates an instance.

Method Summary

Modifier and Type	Method	Description
int	getCount()	Gets the current reference count, which starts at 0.
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.
SessionContext	getSessionContext()	Gets the session context for this binding.
ConnectionSource	getWriteConnectionSource()	Supply a connection source to a server that can be written to
void	release()	Release a reference to this object.
ReadWriteBinding	retain()	Retain an additional reference to this object.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.mongodb.binding.ReferenceCounted

getCount, release

Constructor Detail

ClusterBinding

public ClusterBinding(Cluster cluster,
                      ReadPreference readPreference)

Creates an instance.

Parameters:

cluster - a non-null Cluster which will be used to select a server to bind to

readPreference - a non-null ReadPreference for read operations

Method Detail

retain

public ReadWriteBinding retain()

Description copied from interface: ReferenceCounted

Retain an additional reference to this object. All retained references must be released, or there will be a leak.

Specified by:

retain in interface ReadBinding

Specified by:

retain in interface ReadWriteBinding

Specified by:

retain in interface ReferenceCounted

Specified by:

retain in interface WriteBinding

Returns:

this

getReadPreference

public ReadPreference getReadPreference()

Description copied from interface: ReadBinding

The read preference that all connection sources returned by this instance will satisfy.

Specified by:

getReadPreference in interface ReadBinding

Returns:

the non-null read preference

getReadConnectionSource

public ConnectionSource getReadConnectionSource()

Description copied from interface: ReadBinding

Returns a connection source to a server that satisfies the specified read preference.

Specified by:

getReadConnectionSource in interface ReadBinding

Returns:

the connection source

getSessionContext

public SessionContext getSessionContext()

Description copied from interface: ReadBinding

Gets the session context for this binding.

Specified by:

getSessionContext in interface ReadBinding

Specified by:

getSessionContext in interface WriteBinding

Returns:

the session context, which may not be null

getWriteConnectionSource

public ConnectionSource getWriteConnectionSource()

Description copied from interface: WriteBinding

Supply a connection source to a server that can be written to

Specified by:

getWriteConnectionSource in interface WriteBinding

Returns:

a connection source

getCount

public int getCount()

Description copied from interface: ReferenceCounted

Gets the current reference count, which starts at 0.

Specified by:

getCount in interface ReferenceCounted

Returns:

the current count, which must be greater than or equal to 0

release

public void release()

Description copied from interface: ReferenceCounted

Release a reference to this object.

Specified by:

release in interface ReferenceCounted