org.apache.hedwig.client.netty.impl.multiplex

Class MultiplexSubscribeResponseHandler

java.lang.Object

org.apache.hedwig.client.handlers.AbstractResponseHandler

org.apache.hedwig.client.handlers.SubscribeResponseHandler

org.apache.hedwig.client.netty.impl.AbstractSubscribeResponseHandler

org.apache.hedwig.client.netty.impl.multiplex.MultiplexSubscribeResponseHandler

public class MultiplexSubscribeResponseHandler
extends AbstractSubscribeResponseHandler

Field Summary

Fields inherited from class org.apache.hedwig.client.netty.impl.AbstractSubscribeResponseHandler

aChannelManager, disconnectLock, subscriptions

Fields inherited from class org.apache.hedwig.client.handlers.AbstractResponseHandler

cfg, channelManager

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	asyncCloseSubscription(TopicSubscriber topicSubscriber, Callback<PubSubProtocol.ResponseBody> callback, Object context) Close subscription from this handler.
void	handleResponse(PubSubProtocol.PubSubResponse response, PubSubData pubSubData, org.jboss.netty.channel.Channel channel) Logic to handle received response.
protected Either<PubSubProtocol.StatusCode,HChannel>	handleSuccessResponse(TopicSubscriber ts, PubSubData pubSubData, org.jboss.netty.channel.Channel channel) Handle success response for a specific TopicSubscriber ts.

Methods inherited from class org.apache.hedwig.client.netty.impl.AbstractSubscribeResponseHandler

asyncMessageDeliver, consume, createActiveSubscriber, getActiveSubscriber, getConfiguration, getHChannelManager, handleSubscribeMessage, handleSubscriptionEvent, hasSubscription, messageConsumed, onChannelDisconnected, postHandleSuccessResponse, processSubscriptionEvent, removeSubscription, resubscribeIfNecessary, startDelivery, stopDelivery

Methods inherited from class org.apache.hedwig.client.handlers.AbstractResponseHandler

handleRedirectResponse

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiplexSubscribeResponseHandler

protected MultiplexSubscribeResponseHandler(ClientConfiguration cfg,
                                            HChannelManager channelManager)

Method Detail

handleResponse

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

Description copied from class: AbstractResponseHandler

Logic to handle received response.

Overrides:

handleResponse in class AbstractSubscribeResponseHandler

Parameters:

response - PubSubResponse received from hub server.

pubSubData - PubSubData for the pub/sub request.

channel - Channel we used to make the request.

Throws:

Exception

handleSuccessResponse

protected Either<PubSubProtocol.StatusCode,HChannel> handleSuccessResponse(TopicSubscriber ts,
                                                                           PubSubData pubSubData,
                                                                           org.jboss.netty.channel.Channel channel)

Description copied from class: AbstractSubscribeResponseHandler

Handle success response for a specific TopicSubscriber ts. The method is triggered after subscribed successfully.

Specified by:

handleSuccessResponse in class AbstractSubscribeResponseHandler

Parameters:

ts - Topic Subscriber.

pubSubData - Pub/Sub Request data for this subscribe request.

channel - Subscription Channel.

Returns:

status code to indicate what happened

asyncCloseSubscription

public void asyncCloseSubscription(TopicSubscriber topicSubscriber,
                                   Callback<PubSubProtocol.ResponseBody> callback,
                                   Object context)

Description copied from class: SubscribeResponseHandler

Close subscription from this handler.

Specified by:

asyncCloseSubscription in class SubscribeResponseHandler

Parameters:

topicSubscriber - Topic Subscriber

callback - Callback when the subscription is closed.

context - Callback context.