org.apache.hedwig.client.handlers

Class MessageConsumeCallback

java.lang.Object

org.apache.hedwig.client.handlers.MessageConsumeCallback

All Implemented Interfaces:

Callback<Void>

public class MessageConsumeCallback
extends Object
implements Callback<Void>

This is the Callback used by the MessageHandlers on the client app when they've finished consuming a subscription message sent from the server asynchronously. This callback back to the client libs will be stateless so we can use a singleton for the class. The object context used should be the MessageConsumeData type. That will contain all of the information needed to call the message consume logic in the client lib HChannelHandler.

Constructor Summary

Constructors

Constructor and Description
MessageConsumeCallback(ClientConfiguration cfg, HChannelManager channelManager)

Method Summary

Modifier and Type	Method and Description
void	operationFailed(Object ctx, PubSubException exception) This method is called when the operation failed due to some reason.
void	operationFinished(Object ctx, Void 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

MessageConsumeCallback

public MessageConsumeCallback(ClientConfiguration cfg,
                              HChannelManager channelManager)

Method Detail

operationFinished

public void operationFinished(Object ctx,
                              Void resultOfOperation)

Description copied from interface: Callback

This method is called when the asynchronous operation finishes

Specified by:

operationFinished in interface Callback<Void>

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<Void>

Parameters:

ctx - The context for the callback

exception - The reason for the failure of the scan