org.apache.hedwig.client.netty.impl.simple

Class SimpleSubscribeResponseHandler

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.simple.SimpleSubscribeResponseHandler

public class SimpleSubscribeResponseHandler
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	SimpleSubscribeResponseHandler(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.
protected ActiveSubscriber	createActiveSubscriber(ClientConfiguration cfg, AbstractHChannelManager channelManager, TopicSubscriber ts, PubSubData op, PubSubProtocol.SubscriptionPreferences preferences, org.jboss.netty.channel.Channel channel, HChannel hChannel)
protected ActiveSubscriber	getActiveSubscriber(TopicSubscriber ts)
void	handleResponse(PubSubProtocol.PubSubResponse response, PubSubData pubSubData, org.jboss.netty.channel.Channel channel) Logic to handle received response.
void	handleSubscribeMessage(PubSubProtocol.PubSubResponse response) Handle Message delivered by the server.
protected Either<PubSubProtocol.StatusCode,HChannel>	handleSuccessResponse(TopicSubscriber ts, PubSubData pubSubData, org.jboss.netty.channel.Channel channel) Handle success response for a specific TopicSubscriber ts.
boolean	hasSubscription(TopicSubscriber ts) Whether the given topic subscriber subscribed thru this handler.
protected void	postHandleSuccessResponse(TopicSubscriber ts, ActiveSubscriber as)
protected boolean	removeSubscription(TopicSubscriber ts, ActiveSubscriber ss)

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

asyncMessageDeliver, consume, getConfiguration, getHChannelManager, handleSubscriptionEvent, messageConsumed, onChannelDisconnected, processSubscriptionEvent, 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

SimpleSubscribeResponseHandler

protected SimpleSubscribeResponseHandler(ClientConfiguration cfg,
                                         HChannelManager channelManager)

Method Detail

createActiveSubscriber

protected ActiveSubscriber createActiveSubscriber(ClientConfiguration cfg,
                                                  AbstractHChannelManager channelManager,
                                                  TopicSubscriber ts,
                                                  PubSubData op,
                                                  PubSubProtocol.SubscriptionPreferences preferences,
                                                  org.jboss.netty.channel.Channel channel,
                                                  HChannel hChannel)

Overrides:

createActiveSubscriber in class AbstractSubscribeResponseHandler

getActiveSubscriber

protected ActiveSubscriber getActiveSubscriber(TopicSubscriber ts)

Overrides:

getActiveSubscriber in class AbstractSubscribeResponseHandler

hasSubscription

public boolean hasSubscription(TopicSubscriber ts)

Description copied from class: SubscribeResponseHandler

Whether the given topic subscriber subscribed thru this handler.

Overrides:

hasSubscription in class AbstractSubscribeResponseHandler

Parameters:

ts - Topic Subscriber

Returns:

whether the given topic subscriber subscribed thru this handler.

removeSubscription

protected boolean removeSubscription(TopicSubscriber ts,
                                     ActiveSubscriber ss)

Overrides:

removeSubscription in class AbstractSubscribeResponseHandler

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

handleSubscribeMessage

public void handleSubscribeMessage(PubSubProtocol.PubSubResponse response)

Description copied from class: SubscribeResponseHandler

Handle Message delivered by the server.

Overrides:

handleSubscribeMessage in class AbstractSubscribeResponseHandler

Parameters:

response - Message received from the server.

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

postHandleSuccessResponse

protected void postHandleSuccessResponse(TopicSubscriber ts,
                                         ActiveSubscriber as)

Overrides:

postHandleSuccessResponse in class AbstractSubscribeResponseHandler

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.