com.allanbank.mongodb.client.callback

Class BatchedWriteCallback

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.BatchedWriteCallback

All Implemented Interfaces:

Callback<Reply>, ReplyCallback

public class BatchedWriteCallback
extends ReplyLongCallback

BatchedWriteCallback provides the global callback for the batched writes.

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
BatchedWriteCallback(String databaseName, String collectionName, Callback<Long> results, BatchedWrite write, Client client, List<BatchedWrite.Bundle> bundles) Creates a new BatchedWriteCallback.
BatchedWriteCallback(String databaseName, String collectionName, List<Callback<Reply>> realCallbacks, BatchedWrite write, List<BatchedWrite.Bundle> bundles) Creates a new BatchedWriteCallback.

Method Summary

Methods

Modifier and Type	Method and Description
protected void	callback(BatchedWrite.Bundle bundle, Reply result) Callback for a bundle of write operations sent via the write commands.
protected void	exception(BatchedWrite.Bundle bundle, Throwable thrown) Callback for a bundle of write operations sent via the write commands has failed.
void	send() Sends the next set of operations to the server.
void	setClient(Client client) Sets the client to use to send the bundled writes.

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

BatchedWriteCallback

public BatchedWriteCallback(String databaseName,
                    String collectionName,
                    Callback<Long> results,
                    BatchedWrite write,
                    Client client,
                    List<BatchedWrite.Bundle> bundles)

Creates a new BatchedWriteCallback.

Parameters:

databaseName - The name of the database.

collectionName - The name of the collection.

results - The callback for the final results.

write - The original write.

client - The client for sending the bundled write commands.

bundles - The bundled writes.

BatchedWriteCallback

public BatchedWriteCallback(String databaseName,
                    String collectionName,
                    List<Callback<Reply>> realCallbacks,
                    BatchedWrite write,
                    List<BatchedWrite.Bundle> bundles)

Creates a new BatchedWriteCallback.

Parameters:

databaseName - The name of the database.

collectionName - The name of the collection.

realCallbacks - The list of callbacks. One for each write.

write - The original write.

bundles - The bundled writes.

Method Detail

send

public void send()

Sends the next set of operations to the server.

setClient

public void setClient(Client client)

Sets the client to use to send the bundled writes.

Parameters:

client - The new client for the batch.

callback

protected void callback(BatchedWrite.Bundle bundle,
            Reply result)

Callback for a bundle of write operations sent via the write commands.

Parameters:

bundle - The bundle of write operations.

result - The result of the write operations.

exception

protected void exception(BatchedWrite.Bundle bundle,
             Throwable thrown)

Callback for a bundle of write operations sent via the write commands has failed.

Parameters:

bundle - The bundle of write operations.

thrown - The error for the operations.