org.apache.hedwig.client.handlers

Class PubSubCallback

java.lang.Object

org.apache.hedwig.client.handlers.PubSubCallback

All Implemented Interfaces:

Callback<PubSubProtocol.ResponseBody>

public class PubSubCallback
extends Object
implements Callback<PubSubProtocol.ResponseBody>

This class is used when we are doing synchronous type of operations. All underlying client ops in Hedwig are async so this is just a way to make the async calls synchronous.

Constructor Summary

Constructors

Constructor and Description
PubSubCallback(PubSubData pubSubData)

Method Summary

Modifier and Type	Method and Description
PubSubException	getFailureException()
boolean	getIsCallSuccessful()
PubSubProtocol.ResponseBody	getResponseBody()
void	operationFailed(Object ctx, PubSubException exception) This method is called when the operation failed due to some reason.
void	operationFinished(Object ctx, PubSubProtocol.ResponseBody resultOfOperation) This method is called when the asynchronous operation finishes

Methods inherited from class java.lang.Object

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

Constructor Detail

PubSubCallback

public PubSubCallback(PubSubData pubSubData)

Method Detail

operationFinished

public void operationFinished(Object ctx,
                              PubSubProtocol.ResponseBody resultOfOperation)

Description copied from interface: Callback

This method is called when the asynchronous operation finishes

Specified by:

operationFinished in interface Callback<PubSubProtocol.ResponseBody>

operationFailed

public void operationFailed(Object ctx,
                            PubSubException exception)

Description copied from interface: Callback

This method is called when the operation failed due to some reason. The reason for failure is passed in.

Specified by:

operationFailed in interface Callback<PubSubProtocol.ResponseBody>

Parameters:

ctx - The context for the callback

exception - The reason for the failure of the scan

getIsCallSuccessful

public boolean getIsCallSuccessful()

getFailureException

public PubSubException getFailureException()

getResponseBody

public PubSubProtocol.ResponseBody getResponseBody()