com.mongodb.connection

Class GetMoreProtocol<T>

java.lang.Object

com.mongodb.connection.GetMoreProtocol<T>

Type Parameters:

T - the type of document to decode query results to

All Implemented Interfaces:

Protocol<QueryResult<T>>

class GetMoreProtocol<T>
extends java.lang.Object
implements Protocol<QueryResult<T>>

An implementation of the OP_GET_MORE protocol.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	GetMoreProtocol.GetMoreResultCallback

Field Summary

Fields

Modifier and Type	Field and Description
private static java.lang.String	COMMAND_NAME
private CommandListener	commandListener
private long	cursorId
static Logger	LOGGER
private MongoNamespace	namespace
private int	numberToReturn
private Decoder<T>	resultDecoder

Constructor Summary

Constructors

Constructor and Description
GetMoreProtocol(MongoNamespace namespace, long cursorId, int numberToReturn, Decoder<T> resultDecoder) Construct an instance.

Method Summary

Modifier and Type	Method and Description
private BsonDocument	asGetMoreCommandDocument()
private BsonDocument	asGetMoreCommandResponseDocument(QueryResult<T> queryResult, ResponseBuffers responseBuffers)
QueryResult<T>	execute(InternalConnection connection) Execute the protocol.
void	executeAsync(InternalConnection connection, SingleResultCallback<QueryResult<T>> callback) Execute the protocol asynchronously.
private void	sendMessage(GetMoreMessage message, InternalConnection connection)
void	setCommandListener(CommandListener commandListener)

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

public static final Logger LOGGER

COMMAND_NAME

private static final java.lang.String COMMAND_NAME

See Also:

Constant Field Values

resultDecoder

private final Decoder<T> resultDecoder

namespace

private final MongoNamespace namespace

cursorId

private final long cursorId

numberToReturn

private final int numberToReturn

commandListener

private CommandListener commandListener

Constructor Detail

GetMoreProtocol

public GetMoreProtocol(MongoNamespace namespace,
                       long cursorId,
                       int numberToReturn,
                       Decoder<T> resultDecoder)

Construct an instance.

Parameters:

namespace - the namespace

cursorId - the cursor id

numberToReturn - the number of documents to return

resultDecoder - the decoder for the result documents.

Method Detail

execute

public QueryResult<T> execute(InternalConnection connection)

Description copied from interface: Protocol

Execute the protocol.

Specified by:

execute in interface Protocol<QueryResult<T>>

Parameters:

connection - the connection to execute the protocol on

Returns:

the response from execution of the protocol

executeAsync

public void executeAsync(InternalConnection connection,
                         SingleResultCallback<QueryResult<T>> callback)

Description copied from interface: Protocol

Execute the protocol asynchronously.

Specified by:

executeAsync in interface Protocol<QueryResult<T>>

Parameters:

connection - the connection to execute the protocol on

callback - the callback that is passed the result of the execution

setCommandListener

public void setCommandListener(CommandListener commandListener)

Specified by:

setCommandListener in interface Protocol<QueryResult<T>>

sendMessage

private void sendMessage(GetMoreMessage message,
                         InternalConnection connection)

asGetMoreCommandDocument

private BsonDocument asGetMoreCommandDocument()

asGetMoreCommandResponseDocument

private BsonDocument asGetMoreCommandResponseDocument(QueryResult<T> queryResult,
                                                      ResponseBuffers responseBuffers)