com.mongodb.async.client

Class ClientSessionBinding

java.lang.Object

com.mongodb.async.client.ClientSessionBinding

All Implemented Interfaces:

AsyncReadBinding, AsyncReadWriteBinding, AsyncWriteBinding, ReferenceCounted

class ClientSessionBinding
extends java.lang.Object
implements AsyncReadWriteBinding

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	ClientSessionBinding.SessionBindingAsyncConnectionSource

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	ownsSession
private ClientSession	session
private ClientSessionContext	sessionContext
private AsyncReadWriteBinding	wrapped

Constructor Summary

Constructors

Constructor and Description
ClientSessionBinding(ClientSession session, boolean ownsSession, AsyncReadWriteBinding wrapped)

Method Summary

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

Field Detail

wrapped

private final AsyncReadWriteBinding wrapped

session

private final ClientSession session

ownsSession

private final boolean ownsSession

sessionContext

private final ClientSessionContext sessionContext

Constructor Detail

ClientSessionBinding

ClientSessionBinding(ClientSession session,
                     boolean ownsSession,
                     AsyncReadWriteBinding wrapped)

Method Detail

getReadPreference

public ReadPreference getReadPreference()

Description copied from interface: AsyncReadBinding

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

Specified by:

getReadPreference in interface AsyncReadBinding

Returns:

the non-null read preference

getWriteConnectionSource

public void getWriteConnectionSource(SingleResultCallback<AsyncConnectionSource> callback)

Description copied from interface: AsyncWriteBinding

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

Specified by:

getWriteConnectionSource in interface AsyncWriteBinding

Parameters:

callback - the to be passed the connection source

getSessionContext

public SessionContext getSessionContext()

Description copied from interface: AsyncReadBinding

Gets the session context for this binding.

Specified by:

getSessionContext in interface AsyncReadBinding

Specified by:

getSessionContext in interface AsyncWriteBinding

Returns:

the session context, which may not be null

getReadConnectionSource

public void getReadConnectionSource(SingleResultCallback<AsyncConnectionSource> callback)

Description copied from interface: AsyncReadBinding

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

Specified by:

getReadConnectionSource in interface AsyncReadBinding

Parameters:

callback - the to be passed the 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

retain

public AsyncReadWriteBinding 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 AsyncReadBinding

Specified by:

retain in interface AsyncReadWriteBinding

Specified by:

retain in interface AsyncWriteBinding

Specified by:

retain in interface ReferenceCounted

Returns:

this

release

public void release()

Description copied from interface: ReferenceCounted

Release a reference to this object.

Specified by:

release in interface ReferenceCounted

closeSessionIfCountIsZero

private void closeSessionIfCountIsZero()