com.allanbank.mongodb.client.callback

Class BatchedInsertCountingCallback

java.lang.Object

com.allanbank.mongodb.client.callback.BatchedInsertCountingCallback

All Implemented Interfaces:

Callback<Reply>

public class BatchedInsertCountingCallback
extends Object
implements Callback<Reply>

BatchedInsertCountingCallback is designed to work with the BatchedWriteCallback. This callback can be used as the callback for a series of individual writes and will coalesce the results into a single result based on a an expected number of callbacks.

The class does not track the input n value and instead always returns an N value based on the expected count. That limits the utility of this class to inserts.

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

Constructor Summary

Constructors

Constructor and Description
BatchedInsertCountingCallback(Callback<Reply> forwardCallback, int expectedCount) Creates a new CountingCallback.

Method Summary

Methods

Modifier and Type	Method and Description
void	callback(Reply result) Called when the MongoDB operation has completed with the result of the operation.
void	exception(Throwable thrown) Called when the operation fails due to an exception.

Methods inherited from class java.lang.Object

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

Constructor Detail

BatchedInsertCountingCallback

public BatchedInsertCountingCallback(Callback<Reply> forwardCallback,
                             int expectedCount)

Creates a new CountingCallback.

Parameters:

forwardCallback - The callback to notify with the final results once we receive them all.

expectedCount - The expected number of callbacks.

Method Detail

callback

public void callback(Reply result)

Called when the MongoDB operation has completed with the result of the operation.

Overridden to increment the count and when the max is reached forward the final results.

Specified by:

callback in interface Callback<Reply>

Parameters:

result - The result of the operation.

exception

public void exception(Throwable thrown)

Called when the operation fails due to an exception.

Overridden to record the exception details.

Specified by:

exception in interface Callback<Reply>

Parameters:

thrown - The thrown exception.