com.mongodb.connection

Class KillCursorProtocol

java.lang.Object

com.mongodb.connection.KillCursorProtocol

All Implemented Interfaces:

LegacyProtocol<java.lang.Void>

class KillCursorProtocol
extends java.lang.Object
implements LegacyProtocol<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)

Method Summary

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

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

Method Detail

execute

public java.lang.Void execute(InternalConnection connection)

Specified by:

execute in interface LegacyProtocol<java.lang.Void>

executeAsync

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

Specified by:

executeAsync in interface LegacyProtocol<java.lang.Void>

setCommandListener

public void setCommandListener(CommandListener commandListener)

Specified by:

setCommandListener in interface LegacyProtocol<java.lang.Void>

asCommandDocument

private BsonDocument asCommandDocument()

asCommandResponseDocument

private BsonDocument asCommandResponseDocument()

getCursorIdListAsString

private java.lang.String getCursorIdListAsString()