com.allanbank.mongodb.client.callback

Class BatchedNativeWriteCallback

java.lang.Object

com.allanbank.mongodb.client.callback.AbstractValidatingReplyCallback

com.allanbank.mongodb.client.callback.AbstractReplyCallback<Long>

com.allanbank.mongodb.client.callback.ReplyLongCallback

com.allanbank.mongodb.client.callback.BatchedNativeWriteCallback

All Implemented Interfaces:

Callback<Reply>, ReplyCallback

public class BatchedNativeWriteCallback
extends ReplyLongCallback

BatchedWriteCallback provides the global callback for the batched writes when the server does not support the write commands. This callback will issue the writes using the original wire protocol.

API Warning:

This class is NOT part of the drivers API. This class may be mutated in incompatible ways between any two releases of the driver.

Copyright ©:

2014, Allanbank Consulting, Inc., All Rights Reserved

Field Summary

Fields inherited from class com.allanbank.mongodb.client.callback.ReplyLongCallback

DEFAULT_NAME

Fields inherited from class com.allanbank.mongodb.client.callback.AbstractValidatingReplyCallback

ERROR_CODE_FIELD, ERROR_MESSAGE_FIELDS

Constructor Summary

Constructors

Constructor and Description
BatchedNativeWriteCallback(Callback<Long> results, BatchedWrite write, AbstractMongoOperations collection, List<WriteOperation> operations) Creates a new BatchedWriteCallback.

Method Summary

Methods

Modifier and Type	Method and Description
protected void	callback(WriteOperation operation, long result) Callback for a single write operation sent via the native messages.
protected void	exception(WriteOperation operation, Throwable thrown) Callback for a single write operation sent via the native messages has failed.
void	send() Sends the next set of operations to the server.

Methods inherited from class com.allanbank.mongodb.client.callback.ReplyLongCallback

asError, convert, toLong

Methods inherited from class com.allanbank.mongodb.client.callback.AbstractReplyCallback

exception, getForwardCallback, handle, isLightWeight

Methods inherited from class com.allanbank.mongodb.client.callback.AbstractValidatingReplyCallback

asError, asError, asError, asString, callback, checkForError, toInt, verify

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchedNativeWriteCallback

public BatchedNativeWriteCallback(Callback<Long> results,
                          BatchedWrite write,
                          AbstractMongoOperations collection,
                          List<WriteOperation> operations)

Creates a new BatchedWriteCallback.

Parameters:

results - The callback for the final results.

write - The original write.

collection - The collection for sending the operations.

operations - The operations to send.

Method Detail

send

public void send()

Sends the next set of operations to the server.

callback

protected void callback(WriteOperation operation,
            long result)

Callback for a single write operation sent via the native messages.

Parameters:

operation - The write operation.

result - The result of the write operation.

exception

protected void exception(WriteOperation operation,
             Throwable thrown)

Callback for a single write operation sent via the native messages has failed.

Parameters:

operation - The write operation.

thrown - The error for the operation.