org.apache.hedwig.client.netty

Interface HChannelManager

All Known Implementing Classes:

AbstractHChannelManager, MultiplexHChannelManager, SimpleHChannelManager

public interface HChannelManager

A manager manages 1) all channels established to hub servers, 2) the actions taken by the topic subscribers.

Method Summary

Modifier and Type	Method and Description
void	asyncCloseSubscription(TopicSubscriber topicSubscriber, Callback<PubSubProtocol.ResponseBody> callback, Object context) Close the subscription of the given topicSubscriber.
void	close() Close the channel manager.
SubscribeResponseHandler	getSubscribeResponseHandler(TopicSubscriber topicSubscriber) Get the subscribe response handler managed the given topicSubscriber.
SubscriptionEventEmitter	getSubscriptionEventEmitter() Return the subscription event emitter to emit subscription events.
boolean	isClosed() Is the channel manager closed.
long	nextTxnId() Generate next transaction id for pub/sub request sending thru this manager.
void	redirectToHost(PubSubData pubSubData, InetSocketAddress host) Submit a pub/sub request to a given host.
void	schedule(TimerTask task, long delay) Schedule a timer task after a given delay.
void	startDelivery(TopicSubscriber topicSubscriber, MessageHandler messageHandler) Start delivering messages for a given topic subscriber.
void	stopDelivery(TopicSubscriber topicSubscriber) Stop delivering messages for a given topic subscriber.
void	submitOp(PubSubData pubSubData) Submit a pub/sub request.
void	submitOpAfterDelay(PubSubData op, long delay) Submit a pub/sub request after a given delay.
void	submitOpToDefaultServer(PubSubData pubSubData) Submit a pub/sub request to default server.

Method Detail

submitOpAfterDelay

void submitOpAfterDelay(PubSubData op,
                        long delay)

Submit a pub/sub request after a given delay.

Parameters:

op - Pub/Sub Request.

delay - Delay time in ms.

submitOp

void submitOp(PubSubData pubSubData)

Submit a pub/sub request.

Parameters:

pubSubData - Pub/Sub Request.

submitOpToDefaultServer

void submitOpToDefaultServer(PubSubData pubSubData)

Submit a pub/sub request to default server.

Parameters:

pubSubData - Pub/Sub request.

redirectToHost

void redirectToHost(PubSubData pubSubData,
                    InetSocketAddress host)

Submit a pub/sub request to a given host.

Parameters:

pubSubData - Pub/Sub request.

host - Given host address.

nextTxnId

long nextTxnId()

Generate next transaction id for pub/sub request sending thru this manager.

Returns:

next transaction id.

schedule

void schedule(TimerTask task,
              long delay)

Schedule a timer task after a given delay.

Parameters:

task - A timer task

delay - Delay time in ms.

getSubscribeResponseHandler

SubscribeResponseHandler getSubscribeResponseHandler(TopicSubscriber topicSubscriber)

Get the subscribe response handler managed the given topicSubscriber.

Parameters:

topicSubscriber - Topic Subscriber

Returns:

subscribe response handler managed it, otherwise return null.

startDelivery

void startDelivery(TopicSubscriber topicSubscriber,
                   MessageHandler messageHandler)
            throws PubSubException.ClientNotSubscribedException,
                   AlreadyStartDeliveryException

Start delivering messages for a given topic subscriber.

Parameters:

topicSubscriber - Topic Subscriber

messageHandler - MessageHandler to register for this ResponseHandler instance.

Throws:

PubSubException.ClientNotSubscribedException - If the client is not currently subscribed to the topic

AlreadyStartDeliveryException - If someone started delivery a message handler before stopping existed one.

stopDelivery

void stopDelivery(TopicSubscriber topicSubscriber)
           throws PubSubException.ClientNotSubscribedException

Stop delivering messages for a given topic subscriber.

Parameters:

topicSubscriber - Topic Subscriber

Throws:

PubSubException.ClientNotSubscribedException - If the client is not currently subscribed to the topic

asyncCloseSubscription

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

Close the subscription of the given topicSubscriber.

Parameters:

topicSubscriber - Topic Subscriber

callback - Callback

context - Callback context

getSubscriptionEventEmitter

SubscriptionEventEmitter getSubscriptionEventEmitter()

Return the subscription event emitter to emit subscription events.

Returns:

subscription event emitter.

isClosed

boolean isClosed()

Is the channel manager closed.

Returns:

true if the channel manager is closed, otherwise return false.

close

void close()

Close the channel manager.