com.mongodb.connection

Class KillCursorProtocol

java.lang.Object

com.mongodb.connection.KillCursorProtocol

All Implemented Interfaces:

Protocol<java.lang.Void>

class KillCursorProtocol
extends java.lang.Object
implements Protocol<java.lang.Void>

An implementation of the OP_KILL_CURSOR protocol.

Field Summary

Fields

Modifier and Type	Field and Description
private static java.lang.String	COMMAND_NAME
private CommandListener	commandListener
private java.util.List<java.lang.Long>	cursors
static Logger	LOGGER
private MongoNamespace	namespace

Constructor Summary

Constructors

Constructor and Description
KillCursorProtocol(MongoNamespace namespace, java.util.List<java.lang.Long> cursors) Construct an instance.

Method Summary

Modifier and Type	Method and Description
private BsonDocument	asCommandDocument()
private BsonDocument	asCommandResponseDocument()
java.lang.Void	execute(InternalConnection connection) Execute the protocol.
void	executeAsync(InternalConnection connection, SingleResultCallback<java.lang.Void> callback) Execute the protocol asynchronously.
private java.lang.String	getCursorIdListAsString()
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

namespace

private final MongoNamespace namespace

cursors

private final java.util.List<java.lang.Long> cursors

commandListener

private CommandListener commandListener

Constructor Detail

KillCursorProtocol

public KillCursorProtocol(MongoNamespace namespace,
                          java.util.List<java.lang.Long> cursors)

Construct an instance.

Parameters:

namespace - the namespace in which all the cursors live

cursors - the list of cursors to kill

Method Detail

execute

public java.lang.Void execute(InternalConnection connection)

Description copied from interface: Protocol

Execute the protocol.

Specified by:

execute in interface Protocol<java.lang.Void>

Parameters:

connection - the connection to execute the protocol on

Returns:

the response from execution of the protocol

executeAsync

public void executeAsync(InternalConnection connection,
                         SingleResultCallback<java.lang.Void> callback)

Description copied from interface: Protocol

Execute the protocol asynchronously.

Specified by:

executeAsync in interface Protocol<java.lang.Void>

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<java.lang.Void>

asCommandDocument

private BsonDocument asCommandDocument()

asCommandResponseDocument

private BsonDocument asCommandResponseDocument()

getCursorIdListAsString

private java.lang.String getCursorIdListAsString()