Package | Description |
---|---|
org.apache.hedwig.client.netty.impl | |
org.apache.hedwig.client.netty.impl.simple |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<TopicSubscriber,ActiveSubscriber> |
AbstractSubscribeResponseHandler.subscriptions |
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) |
protected ActiveSubscriber |
AbstractSubscribeResponseHandler.getActiveSubscriber(TopicSubscriber ts) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractSubscribeResponseHandler.postHandleSuccessResponse(TopicSubscriber ts,
ActiveSubscriber ss) |
protected void |
AbstractSubscribeResponseHandler.processSubscriptionEvent(ActiveSubscriber as,
PubSubProtocol.SubscriptionEvent event) |
protected boolean |
AbstractSubscribeResponseHandler.removeSubscription(TopicSubscriber ts,
ActiveSubscriber ss) |
protected void |
AbstractSubscribeResponseHandler.resubscribeIfNecessary(ActiveSubscriber ss,
PubSubProtocol.SubscriptionEvent event) |
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) |
protected ActiveSubscriber |
SimpleSubscribeResponseHandler.getActiveSubscriber(TopicSubscriber ts) |
Modifier and Type | Method and Description |
---|---|
protected void |
SimpleSubscribeResponseHandler.postHandleSuccessResponse(TopicSubscriber ts,
ActiveSubscriber as) |
protected boolean |
SimpleSubscribeResponseHandler.removeSubscription(TopicSubscriber ts,
ActiveSubscriber ss) |
Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.