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 |
Modifier and Type | Method and Description |
---|---|
HChannel |
PubSubData.getOriginalChannelForResubscribe() |
Modifier and Type | Method and Description |
---|---|
void |
PubSubData.setOriginalChannelForResubscribe(HChannel channel) |
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 . |
Modifier and Type | Method and Description |
---|---|
Collection<HChannel> |
CleanupChannelMap.getChannels()
Return the channels in the map.
|
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 . |
Modifier and Type | Class and Description |
---|---|
class |
HChannelImpl
Provide a wrapper over netty channel for Hedwig operations.
|
Modifier and Type | Field and Description |
---|---|
protected HChannel |
ActiveSubscriber.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 . |
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 . |
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) |
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.
|
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) |
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) |
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) |
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) |
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) |
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) |
Copyright © 2011–2019 The Apache Software Foundation. All rights reserved.