com.allanbank.mongodb.client.state

Class ServerUpdateCallback

java.lang.Object

com.allanbank.mongodb.client.FutureCallback<Reply>

com.allanbank.mongodb.client.callback.FutureReplyCallback

com.allanbank.mongodb.client.state.ServerUpdateCallback

All Implemented Interfaces:

Callback<Reply>, ReplyCallback, ListenableFuture<Reply>, Future<Reply>

public class ServerUpdateCallback
extends FutureReplyCallback

ServerUpdateCallback provides a special callback update the server with the first document in the reply. This is useful with ismaster or replSetGetStatus commands.

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 ©:

2012-2014, Allanbank Consulting, Inc., All Rights Reserved

Field Summary

Fields inherited from class com.allanbank.mongodb.client.FutureCallback

LOG, SPIN_TIME_NS

Constructor Summary

Constructors

Constructor and Description
ServerUpdateCallback(Server server) Creates a new ServerUpdateCallback.

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 error) Called when the operation fails due to an exception.

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

isLightWeight

Methods inherited from class com.allanbank.mongodb.client.FutureCallback

addListener, cancel, execute, get, get, isCancelled, isDone

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerUpdateCallback

public ServerUpdateCallback(Server server)

Creates a new ServerUpdateCallback.

Parameters:

server - The server we are tracking the latency for.

Method Detail

callback

public void callback(Reply result)

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

Sets the value for the future and triggers any pending FutureCallback.get() to return.

Overridden to update the server's latency based on the round trip reply time.

Specified by:

callback in interface Callback<Reply>

Overrides:

callback in class FutureCallback<Reply>

Parameters:

result - The result of the operation.

See Also:

Callback.callback(V)

exception

public void exception(Throwable error)

Called when the operation fails due to an exception.

Sets the exception for the future and triggers any pending FutureCallback.get() to throw a ExecutionException.

Overridden to mark the server as Integer.MAX_VALUE seconds behind the primary.

Specified by:

exception in interface Callback<Reply>

Overrides:

exception in class FutureCallback<Reply>

Parameters:

error - The thrown exception.

See Also:

Callback.exception(java.lang.Throwable)