com.allanbank.mongodb.client.callback

Class ReplyHandler

java.lang.Object

com.allanbank.mongodb.client.callback.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-2014, Allanbank Consulting, Inc., All Rights Reserved

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
static void	raiseError(Throwable exception, ReplyCallback replyCallback, Executor executor) Raise an error on the callback, if any.
static void	reply(Receiver receiver, Reply reply, ReplyCallback replyCallback, Executor executor) Updates to set the reply for the callback, if any.
void	run()
static void	tryReceive() If there is a pending reply tries to process that reply.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplyHandler

public ReplyHandler(ReplyCallback replyCallback,
            Reply reply)

Creates a new ReplyHandler.

Parameters:

replyCallback - The callback for the message.

reply - The reply.

ReplyHandler

public ReplyHandler(ReplyCallback 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,
              ReplyCallback 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(Receiver receiver,
         Reply reply,
         ReplyCallback replyCallback,
         Executor executor)

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

Parameters:

receiver - The socket receiving the message.

reply - The reply.

replyCallback - The callback for the reply to the message.

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

tryReceive

public static void tryReceive()

If there is a pending reply tries to process that reply.

run

public void run()

Overridden to process the callback response.

Specified by:

run in interface Runnable