org.apache.hedwig.client.handlers

Class AbstractResponseHandler

java.lang.Object

org.apache.hedwig.client.handlers.AbstractResponseHandler

Direct Known Subclasses:

CloseSubscriptionResponseHandler, PublishResponseHandler, SubscribeResponseHandler, UnsubscribeResponseHandler

public abstract class AbstractResponseHandler
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected ClientConfiguration	cfg
protected HChannelManager	channelManager

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractResponseHandler(ClientConfiguration cfg, HChannelManager channelManager)

Method Summary

Modifier and Type	Method and Description
protected void	handleRedirectResponse(PubSubProtocol.PubSubResponse response, PubSubData pubSubData, org.jboss.netty.channel.Channel channel) Logic to repost a PubSubRequest when the server responds with a redirect indicating they are not the topic master.
abstract void	handleResponse(PubSubProtocol.PubSubResponse response, PubSubData pubSubData, org.jboss.netty.channel.Channel channel) Logic to handle received response.

Methods inherited from class java.lang.Object

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

Field Detail

cfg

protected final ClientConfiguration cfg

channelManager

protected final HChannelManager channelManager

Constructor Detail

AbstractResponseHandler

protected AbstractResponseHandler(ClientConfiguration cfg,
                                  HChannelManager channelManager)

Method Detail

handleResponse

public abstract void handleResponse(PubSubProtocol.PubSubResponse response,
                                    PubSubData pubSubData,
                                    org.jboss.netty.channel.Channel channel)
                             throws Exception

Logic to handle received response.

Parameters:

response - PubSubResponse received from hub server.

pubSubData - PubSubData for the pub/sub request.

channel - Channel we used to make the request.

Throws:

Exception

handleRedirectResponse

protected void handleRedirectResponse(PubSubProtocol.PubSubResponse response,
                                      PubSubData pubSubData,
                                      org.jboss.netty.channel.Channel channel)
                               throws Exception

Logic to repost a PubSubRequest when the server responds with a redirect indicating they are not the topic master.

Parameters:

response - PubSubResponse from the server for the redirect

pubSubData - PubSubData for the original PubSubRequest made

channel - Channel Channel we used to make the original PubSubRequest

Throws:

Exception - Throws an exception if there was an error in doing the redirect repost of the PubSubRequest