Uses of Interface
org.apache.hedwig.client.netty.HChannel

Packages that use HChannel

Package	Description
org.apache.hedwig.client.data
org.apache.hedwig.client.netty	A Netty based Hedwig client implementation.
org.apache.hedwig.client.netty.impl
org.apache.hedwig.client.netty.impl.multiplex
org.apache.hedwig.client.netty.impl.simple

Uses of HChannel in org.apache.hedwig.client.data

Methods in org.apache.hedwig.client.data that return HChannel

Modifier and Type	Method and Description
HChannel	PubSubData.getOriginalChannelForResubscribe()

Methods in org.apache.hedwig.client.data with parameters of type HChannel

Modifier and Type	Method and Description
void	PubSubData.setOriginalChannelForResubscribe(HChannel channel)

Uses of HChannel in org.apache.hedwig.client.netty

Methods in org.apache.hedwig.client.netty that return HChannel

Modifier and Type	Method and Description
HChannel	CleanupChannelMap.addChannel(T key, HChannel channel) Add channel to the map.
HChannel	CleanupChannelMap.getChannel(T key) Returns the channel bound with key.
HChannel	CleanupChannelMap.removeChannel(T key) Remove the channel bound with key.

Methods in org.apache.hedwig.client.netty that return types with arguments of type HChannel

Modifier and Type	Method and Description
Collection<HChannel>	CleanupChannelMap.getChannels() Return the channels in the map.

Methods in org.apache.hedwig.client.netty with parameters of type HChannel

Modifier and Type	Method and Description
HChannel	CleanupChannelMap.addChannel(T key, HChannel channel) Add channel to the map.
boolean	CleanupChannelMap.removeChannel(T key, HChannel channel) Remove the channel bound with key.
boolean	CleanupChannelMap.replaceChannel(T key, HChannel oldChannel, HChannel newChannel) Replace channel only if currently mapped to the given oldChannel.

Uses of HChannel in org.apache.hedwig.client.netty.impl

Classes in org.apache.hedwig.client.netty.impl that implement HChannel

Modifier and Type	Class and Description
class	HChannelImpl Provide a wrapper over netty channel for Hedwig operations.

Fields in org.apache.hedwig.client.netty.impl declared as HChannel

Modifier and Type	Field and Description
protected HChannel	ActiveSubscriber.hChannel

Methods in org.apache.hedwig.client.netty.impl that return HChannel

Modifier and Type	Method and Description
protected abstract HChannel	AbstractHChannelManager.createAndStoreSubscriptionChannel(org.jboss.netty.channel.Channel channel) Create and store a subscription HChannel thru the underlying established channel
protected abstract HChannel	AbstractHChannelManager.createAndStoreSubscriptionChannel(InetSocketAddress host) Create and store a subscription HChannel to target host.
protected abstract HChannel	AbstractHChannelManager.getSubscriptionChannel(InetSocketAddress host) Is there a subscription HChannel existed for a given host.
protected abstract HChannel	AbstractHChannelManager.getSubscriptionChannelByTopicSubscriber(TopicSubscriber topicSubscriber) Get a subscription channel for a given topicSubscriber.

Methods in org.apache.hedwig.client.netty.impl that return types with arguments of type HChannel

Modifier and Type	Method and Description
protected abstract Either<PubSubProtocol.StatusCode,HChannel>	AbstractSubscribeResponseHandler.handleSuccessResponse(TopicSubscriber ts, PubSubData pubSubData, org.jboss.netty.channel.Channel channel) Handle success response for a specific TopicSubscriber ts.

Methods in org.apache.hedwig.client.netty.impl with parameters of type HChannel

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

Constructors in org.apache.hedwig.client.netty.impl with parameters of type HChannel

Constructor and Description
ActiveSubscriber(ClientConfiguration cfg, AbstractHChannelManager channelManager, TopicSubscriber ts, PubSubData op, PubSubProtocol.SubscriptionPreferences preferences, org.jboss.netty.channel.Channel channel, HChannel hChannel) Construct an active subscriber instance.

Uses of HChannel in org.apache.hedwig.client.netty.impl.multiplex

Methods in org.apache.hedwig.client.netty.impl.multiplex that return HChannel

Modifier and Type	Method and Description
protected HChannel	MultiplexHChannelManager.createAndStoreSubscriptionChannel(org.jboss.netty.channel.Channel channel)
protected HChannel	MultiplexHChannelManager.createAndStoreSubscriptionChannel(InetSocketAddress host)
protected HChannel	MultiplexHChannelManager.getSubscriptionChannel(InetSocketAddress host)
protected HChannel	MultiplexHChannelManager.getSubscriptionChannel(TopicSubscriber subscriber)
protected HChannel	MultiplexHChannelManager.getSubscriptionChannelByTopicSubscriber(TopicSubscriber subscriber)

Methods in org.apache.hedwig.client.netty.impl.multiplex that return types with arguments of type HChannel

Modifier and Type	Method and Description
protected Either<PubSubProtocol.StatusCode,HChannel>	MultiplexSubscribeResponseHandler.handleSuccessResponse(TopicSubscriber ts, PubSubData pubSubData, org.jboss.netty.channel.Channel channel)
protected Either<Boolean,HChannel>	MultiplexHChannelManager.storeSubscriptionChannel(TopicSubscriber topicSubscriber, PubSubData txn, HChannel channel)

Methods in org.apache.hedwig.client.netty.impl.multiplex with parameters of type HChannel

Modifier and Type	Method and Description
protected boolean	MultiplexHChannelManager.removeSubscriptionChannel(TopicSubscriber topicSubscriber, HChannel channel)
protected Either<Boolean,HChannel>	MultiplexHChannelManager.storeSubscriptionChannel(TopicSubscriber topicSubscriber, PubSubData txn, HChannel channel)

Uses of HChannel in org.apache.hedwig.client.netty.impl.simple

Methods in org.apache.hedwig.client.netty.impl.simple that return HChannel

Modifier and Type	Method and Description
protected HChannel	SimpleHChannelManager.createAndStoreSubscriptionChannel(org.jboss.netty.channel.Channel channel)
protected HChannel	SimpleHChannelManager.createAndStoreSubscriptionChannel(InetSocketAddress host)
protected HChannel	SimpleHChannelManager.getSubscriptionChannel(InetSocketAddress host)
protected HChannel	SimpleHChannelManager.getSubscriptionChannelByTopicSubscriber(TopicSubscriber subscriber)

Methods in org.apache.hedwig.client.netty.impl.simple that return types with arguments of type HChannel

Modifier and Type	Method and Description
protected Either<PubSubProtocol.StatusCode,HChannel>	SimpleSubscribeResponseHandler.handleSuccessResponse(TopicSubscriber ts, PubSubData pubSubData, org.jboss.netty.channel.Channel channel)
protected Either<Boolean,HChannel>	SimpleHChannelManager.storeSubscriptionChannel(TopicSubscriber topicSubscriber, PubSubData txn, org.jboss.netty.channel.Channel channel)

Methods in org.apache.hedwig.client.netty.impl.simple with parameters of type HChannel

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