com.allanbank.mongodb.connection.message

Class ReplyHandler

java.lang.Object

com.allanbank.mongodb.connection.message.ReplyHandler

All Implemented Interfaces:

Runnable

public class ReplyHandler
extends Object
implements Runnable

ReplyHandler provides the capability to properly handle the replies to a callback.

Copyright ©:

2012, Allanbank Consulting, Inc., All Rights Reserved

Constructor Summary

Constructors

Constructor and Description
ReplyHandler(Callback<Reply> replyCallback, Reply reply) Creates a new ReplyHandler.
ReplyHandler(Callback<Reply> replyCallback, Throwable exception) Creates a new ReplyHandler.

Method Summary

Methods

Modifier and Type	Method and Description
static void	raiseError(Throwable exception, Callback<Reply> replyCallback, Executor executor) Raise an error on the callback, if any.
static void	reply(Reply reply, Callback<Reply> replyCallback, Executor executor) Updates to set the reply for the callback, if any.
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplyHandler

public ReplyHandler(Callback<Reply> replyCallback,
            Reply reply)

Creates a new ReplyHandler.

Parameters:

replyCallback - The callback for the message.

reply - The reply.

ReplyHandler

public ReplyHandler(Callback<Reply> replyCallback,
            Throwable exception)

Creates a new ReplyHandler.

Parameters:

replyCallback - The callback for the message.

exception - The thrown exception.

Method Detail

raiseError

public static void raiseError(Throwable exception,
              Callback<Reply> replyCallback,
              Executor executor)

Raise an error on the callback, if any. Will execute the request on a background thread if provided.

Parameters:

exception - The thrown exception.

replyCallback - The callback for the reply to the message.

executor - The executor to use for the back-grounding the reply handling.

reply

public static void reply(Reply reply,
         Callback<Reply> replyCallback,
         Executor executor)

Updates to set the reply for the callback, if any.

Parameters:

reply - The reply.

replyCallback - The callback for the reply to the message.

executor - The executor to use for the back-grounding the reply handling.

run

public void run()

Overridden to process the callback response.

Specified by:

run in interface Runnable