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

Class MultiplexHChannelManager

java.lang.Object

org.apache.hedwig.client.netty.impl.AbstractHChannelManager

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

All Implemented Interfaces:

HChannelManager

public class MultiplexHChannelManager
extends AbstractHChannelManager

Multiplex HChannel Manager which establish a connection for multi subscriptions.

Field Summary

Fields

Modifier and Type	Field and Description
protected CleanupChannelMap<TopicSubscriber>	sub2Channels
protected CleanupChannelMap<InetSocketAddress>	subscriptionChannels
protected ConcurrentMap<TopicSubscriber,MessageHandler>	topicSubscriber2MessageHandler

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

closed, closedLock, globalCounter, host2NonSubscriptionChannels, host2Topics, socketFactory, topic2Host

Constructor Summary

Constructors

Constructor and Description
MultiplexHChannelManager(ClientConfiguration cfg, org.jboss.netty.channel.ChannelFactory socketFactory)

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.
protected void	checkTimeoutRequestsOnSubscriptionChannels() Chekout the pub/sub requests on subscription channels.
protected void	closeSubscriptionChannels() Close all subscription channels when close channel manager.
protected HChannel	createAndStoreSubscriptionChannel(org.jboss.netty.channel.Channel channel) Create and store a subscription HChannel thru the underlying established channel
protected HChannel	createAndStoreSubscriptionChannel(InetSocketAddress host) Create and store a subscription HChannel to target host.
SubscribeResponseHandler	getSubscribeResponseHandler(TopicSubscriber topicSubscriber) Get the subscribe response handler managed the given topicSubscriber.
protected HChannel	getSubscriptionChannel(InetSocketAddress host) Is there a subscription HChannel existed for a given host.
protected HChannel	getSubscriptionChannel(TopicSubscriber subscriber)
protected HChannel	getSubscriptionChannelByTopicSubscriber(TopicSubscriber subscriber) Get a subscription channel for a given topicSubscriber.
protected ClientChannelPipelineFactory	getSubscriptionChannelPipelineFactory()
protected void	onSubscriptionChannelDisconnected(InetSocketAddress host, org.jboss.netty.channel.Channel channel) Handle the disconnected event from a subscription HChannel.
protected boolean	removeSubscriptionChannel(TopicSubscriber topicSubscriber, HChannel channel)
protected void	restartDelivery(TopicSubscriber topicSubscriber)
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.
protected Either<Boolean,HChannel>	storeSubscriptionChannel(TopicSubscriber topicSubscriber, PubSubData txn, HChannel channel)

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

clearAllTopicsForHost, clearHostForTopic, close, getChannelFactory, getConsumeCallback, getNonSubscriptionChannelPipelineFactory, getSslFactory, getSubscriptionEventEmitter, isClosed, nextTxnId, onNonSubscriptionChannelDisconnected, redirectToHost, schedule, storeTopic2HostMapping, submitOp, submitOpAfterDelay, submitOpToDefaultServer

Methods inherited from class java.lang.Object

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

Field Detail

subscriptionChannels

protected final CleanupChannelMap<InetSocketAddress> subscriptionChannels

sub2Channels

protected final CleanupChannelMap<TopicSubscriber> sub2Channels

topicSubscriber2MessageHandler

protected final ConcurrentMap<TopicSubscriber,MessageHandler> topicSubscriber2MessageHandler

Constructor Detail

MultiplexHChannelManager

public MultiplexHChannelManager(ClientConfiguration cfg,
                                org.jboss.netty.channel.ChannelFactory socketFactory)

Method Detail

getSubscriptionChannelPipelineFactory

protected ClientChannelPipelineFactory getSubscriptionChannelPipelineFactory()

Specified by:

getSubscriptionChannelPipelineFactory in class AbstractHChannelManager

createAndStoreSubscriptionChannel

protected HChannel createAndStoreSubscriptionChannel(org.jboss.netty.channel.Channel channel)

Description copied from class: AbstractHChannelManager

Create and store a subscription HChannel thru the underlying established channel

Specified by:

createAndStoreSubscriptionChannel in class AbstractHChannelManager

Parameters:

channel - The underlying established subscription channel.

createAndStoreSubscriptionChannel

protected HChannel createAndStoreSubscriptionChannel(InetSocketAddress host)

Description copied from class: AbstractHChannelManager

Create and store a subscription HChannel to target host.

Specified by:

createAndStoreSubscriptionChannel in class AbstractHChannelManager

Parameters:

host - Target host address.

getSubscriptionChannel

protected HChannel getSubscriptionChannel(InetSocketAddress host)

Description copied from class: AbstractHChannelManager

Is there a subscription HChannel existed for a given host.

Specified by:

getSubscriptionChannel in class AbstractHChannelManager

Parameters:

host - Target host address.

getSubscriptionChannel

protected HChannel getSubscriptionChannel(TopicSubscriber subscriber)

getSubscriptionChannelByTopicSubscriber

protected HChannel getSubscriptionChannelByTopicSubscriber(TopicSubscriber subscriber)

Description copied from class: AbstractHChannelManager

Get a subscription channel for a given topicSubscriber.

Specified by:

getSubscriptionChannelByTopicSubscriber in class AbstractHChannelManager

Parameters:

subscriber - Topic Subscriber

Returns:

if topic's owner is unknown, return null. if topic's owner is know and there is a channel existed before, return the existed channel, otherwise created a new one for the topicSubscriber.

onSubscriptionChannelDisconnected

protected void onSubscriptionChannelDisconnected(InetSocketAddress host,
                                                 org.jboss.netty.channel.Channel channel)

Description copied from class: AbstractHChannelManager

Handle the disconnected event from a subscription HChannel.

Specified by:

onSubscriptionChannelDisconnected in class AbstractHChannelManager

Parameters:

host - Which host is disconnected.

channel - The underlying established channel.

getSubscribeResponseHandler

public SubscribeResponseHandler getSubscribeResponseHandler(TopicSubscriber topicSubscriber)

Description copied from interface: HChannelManager

Get the subscribe response handler managed the given topicSubscriber.

Parameters:

topicSubscriber - Topic Subscriber

Returns:

subscribe response handler managed it, otherwise return null.

startDelivery

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

Description copied from interface: HChannelManager

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.

restartDelivery

protected void restartDelivery(TopicSubscriber topicSubscriber)
                        throws PubSubException.ClientNotSubscribedException,
                               AlreadyStartDeliveryException

Specified by:

restartDelivery in class AbstractHChannelManager

Throws:

PubSubException.ClientNotSubscribedException

AlreadyStartDeliveryException

stopDelivery

public void stopDelivery(TopicSubscriber topicSubscriber)
                  throws PubSubException.ClientNotSubscribedException

Description copied from interface: HChannelManager

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

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

Description copied from interface: HChannelManager

Close the subscription of the given topicSubscriber.

Parameters:

topicSubscriber - Topic Subscriber

callback - Callback

context - Callback context

checkTimeoutRequestsOnSubscriptionChannels

protected void checkTimeoutRequestsOnSubscriptionChannels()

Description copied from class: AbstractHChannelManager

Chekout the pub/sub requests on subscription channels.

Specified by:

checkTimeoutRequestsOnSubscriptionChannels in class AbstractHChannelManager

closeSubscriptionChannels

protected void closeSubscriptionChannels()

Description copied from class: AbstractHChannelManager

Close all subscription channels when close channel manager.

Specified by:

closeSubscriptionChannels in class AbstractHChannelManager

storeSubscriptionChannel

protected Either<Boolean,HChannel> storeSubscriptionChannel(TopicSubscriber topicSubscriber,
                                                            PubSubData txn,
                                                            HChannel channel)

removeSubscriptionChannel

protected boolean removeSubscriptionChannel(TopicSubscriber topicSubscriber,
                                            HChannel channel)