com.mongodb.connection

Class DeleteCommandProtocol

java.lang.Object

com.mongodb.connection.WriteCommandProtocol

com.mongodb.connection.DeleteCommandProtocol

All Implemented Interfaces:

Protocol<BulkWriteResult>

class DeleteCommandProtocol
extends WriteCommandProtocol

An implementation of the delete command.

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.List<DeleteRequest>	deleteRequests
private static Logger	LOGGER

Constructor Summary

Constructors

Constructor and Description
DeleteCommandProtocol(MongoNamespace namespace, boolean ordered, WriteConcern writeConcern, java.util.List<DeleteRequest> deletes) Construct an instance.

Method Summary

Modifier and Type	Method and Description
protected DeleteCommandMessage	createRequestMessage(MessageSettings messageSettings)
BulkWriteResult	execute(InternalConnection connection) Execute the protocol.
void	executeAsync(InternalConnection connection, SingleResultCallback<BulkWriteResult> callback) Execute the protocol asynchronously.
protected Logger	getLogger() Gets the logger.
protected WriteRequest.Type	getType()

Methods inherited from class com.mongodb.connection.WriteCommandProtocol

getBypassDocumentValidation, getNamespace, getWriteConcern, isOrdered, setCommandListener

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final Logger LOGGER

deleteRequests

private final java.util.List<DeleteRequest> deleteRequests

Constructor Detail

DeleteCommandProtocol

public DeleteCommandProtocol(MongoNamespace namespace,
                             boolean ordered,
                             WriteConcern writeConcern,
                             java.util.List<DeleteRequest> deletes)

Construct an instance.

Parameters:

namespace - the namespace

ordered - whether the inserts are ordered

writeConcern - the write concern

deletes - the list of deletes

Method Detail

execute

public BulkWriteResult execute(InternalConnection connection)

Description copied from interface: Protocol

Execute the protocol.

Specified by:

execute in interface Protocol<BulkWriteResult>

Overrides:

execute in class WriteCommandProtocol

Parameters:

connection - the connection to execute the protocol on

Returns:

the response from execution of the protocol

executeAsync

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

Description copied from interface: Protocol

Execute the protocol asynchronously.

Specified by:

executeAsync in interface Protocol<BulkWriteResult>

Overrides:

executeAsync in class WriteCommandProtocol

Parameters:

connection - the connection to execute the protocol on

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

getType

protected WriteRequest.Type getType()

Specified by:

getType in class WriteCommandProtocol

createRequestMessage

protected DeleteCommandMessage createRequestMessage(MessageSettings messageSettings)

Specified by:

createRequestMessage in class WriteCommandProtocol

getLogger

protected Logger getLogger()

Description copied from class: WriteCommandProtocol

Gets the logger.

Specified by:

getLogger in class WriteCommandProtocol

Returns:

the logger