Package | Description |
---|---|
org.apache.hedwig.client.data | |
org.apache.hedwig.client.handlers | |
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 | Field and Description |
---|---|
TopicSubscriber |
MessageConsumeData.topicSubscriber |
Constructor and Description |
---|
MessageConsumeData(TopicSubscriber topicSubscriber,
PubSubProtocol.Message msg) |
Modifier and Type | Method and Description |
---|---|
abstract void |
SubscribeResponseHandler.asyncCloseSubscription(TopicSubscriber topicSubscriber,
Callback<PubSubProtocol.ResponseBody> callback,
Object context)
Close subscription from this handler.
|
protected abstract void |
SubscribeResponseHandler.asyncMessageDeliver(TopicSubscriber topicSubscriber,
PubSubProtocol.Message message)
Method called when a message arrives for a subscribe Channel and we want
to deliver it asynchronously via the registered MessageHandler (should
not be null when called here).
|
abstract void |
SubscribeResponseHandler.consume(TopicSubscriber topicSubscriber,
PubSubProtocol.MessageSeqId messageSeqId)
Consume a given message for given topic subscriber thru this handler.
|
abstract boolean |
SubscribeResponseHandler.hasSubscription(TopicSubscriber topicSubscriber)
Whether the given topic subscriber subscribed thru this handler.
|
protected abstract void |
SubscribeResponseHandler.messageConsumed(TopicSubscriber topicSubscriber,
PubSubProtocol.Message message)
Method called when the client app's MessageHandler has asynchronously
completed consuming a subscribed message sent from the server.
|
abstract void |
SubscribeResponseHandler.startDelivery(TopicSubscriber topicSubscriber,
MessageHandler messageHandler)
Start delivering messages for a given topic subscriber.
|
abstract void |
SubscribeResponseHandler.stopDelivery(TopicSubscriber topicSubscriber)
Stop delivering messages for a given topic subscriber.
|
Modifier and Type | Method and Description |
---|---|
void |
HChannelManager.asyncCloseSubscription(TopicSubscriber topicSubscriber,
Callback<PubSubProtocol.ResponseBody> callback,
Object context)
Close the subscription of the given
topicSubscriber . |
static PubSubProtocol.PubSubRequest.Builder |
NetUtils.buildConsumeRequest(long txnId,
TopicSubscriber topicSubscriber,
PubSubProtocol.MessageSeqId messageSeqId)
Build consume request
|
SubscribeResponseHandler |
HChannelManager.getSubscribeResponseHandler(TopicSubscriber topicSubscriber)
Get the subscribe response handler managed the given
topicSubscriber . |
void |
HChannelManager.startDelivery(TopicSubscriber topicSubscriber,
MessageHandler messageHandler)
Start delivering messages for a given topic subscriber.
|
void |
HChannelManager.stopDelivery(TopicSubscriber topicSubscriber)
Stop delivering messages for a given topic subscriber.
|
Modifier and Type | Field and Description |
---|---|
protected TopicSubscriber |
ActiveSubscriber.topicSubscriber |
Modifier and Type | Field and Description |
---|---|
protected ConcurrentMap<TopicSubscriber,ActiveSubscriber> |
AbstractSubscribeResponseHandler.subscriptions |
Modifier and Type | Method and Description |
---|---|
TopicSubscriber |
ActiveSubscriber.getTopicSubscriber() |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractSubscribeResponseHandler.asyncMessageDeliver(TopicSubscriber topicSubscriber,
PubSubProtocol.Message message) |
void |
AbstractSubscribeResponseHandler.consume(TopicSubscriber topicSubscriber,
PubSubProtocol.MessageSeqId messageSeqId) |
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) |
protected abstract HChannel |
AbstractHChannelManager.getSubscriptionChannelByTopicSubscriber(TopicSubscriber topicSubscriber)
Get a subscription channel for a given
topicSubscriber . |
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 . |
boolean |
AbstractSubscribeResponseHandler.hasSubscription(TopicSubscriber topicSubscriber) |
protected void |
AbstractSubscribeResponseHandler.messageConsumed(TopicSubscriber topicSubscriber,
PubSubProtocol.Message message) |
protected void |
AbstractSubscribeResponseHandler.postHandleSuccessResponse(TopicSubscriber ts,
ActiveSubscriber ss) |
protected boolean |
AbstractSubscribeResponseHandler.removeSubscription(TopicSubscriber ts,
ActiveSubscriber ss) |
protected abstract void |
AbstractHChannelManager.restartDelivery(TopicSubscriber topicSubscriber) |
void |
AbstractSubscribeResponseHandler.startDelivery(TopicSubscriber topicSubscriber,
MessageHandler messageHandler) |
void |
AbstractSubscribeResponseHandler.stopDelivery(TopicSubscriber topicSubscriber) |
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 | Field and Description |
---|---|
protected CleanupChannelMap<TopicSubscriber> |
MultiplexHChannelManager.sub2Channels |
protected ConcurrentMap<TopicSubscriber,MessageHandler> |
MultiplexHChannelManager.topicSubscriber2MessageHandler |
Modifier and Type | Method and Description |
---|---|
void |
MultiplexHChannelManager.asyncCloseSubscription(TopicSubscriber topicSubscriber,
Callback<PubSubProtocol.ResponseBody> callback,
Object context) |
void |
MultiplexSubscribeResponseHandler.asyncCloseSubscription(TopicSubscriber topicSubscriber,
Callback<PubSubProtocol.ResponseBody> callback,
Object context) |
SubscribeResponseHandler |
MultiplexHChannelManager.getSubscribeResponseHandler(TopicSubscriber topicSubscriber) |
protected HChannel |
MultiplexHChannelManager.getSubscriptionChannel(TopicSubscriber subscriber) |
protected HChannel |
MultiplexHChannelManager.getSubscriptionChannelByTopicSubscriber(TopicSubscriber subscriber) |
protected Either<PubSubProtocol.StatusCode,HChannel> |
MultiplexSubscribeResponseHandler.handleSuccessResponse(TopicSubscriber ts,
PubSubData pubSubData,
org.jboss.netty.channel.Channel channel) |
protected boolean |
MultiplexHChannelManager.removeSubscriptionChannel(TopicSubscriber topicSubscriber,
HChannel channel) |
protected void |
MultiplexHChannelManager.restartDelivery(TopicSubscriber topicSubscriber) |
void |
MultiplexHChannelManager.startDelivery(TopicSubscriber topicSubscriber,
MessageHandler messageHandler) |
void |
MultiplexHChannelManager.stopDelivery(TopicSubscriber topicSubscriber) |
protected Either<Boolean,HChannel> |
MultiplexHChannelManager.storeSubscriptionChannel(TopicSubscriber topicSubscriber,
PubSubData txn,
HChannel channel) |
Modifier and Type | Field and Description |
---|---|
protected CleanupChannelMap<TopicSubscriber> |
SimpleHChannelManager.topicSubscriber2Channel |
protected ConcurrentMap<TopicSubscriber,MessageHandler> |
SimpleHChannelManager.topicSubscriber2MessageHandler |
Modifier and Type | Method and Description |
---|---|
void |
SimpleHChannelManager.asyncCloseSubscription(TopicSubscriber topicSubscriber,
Callback<PubSubProtocol.ResponseBody> callback,
Object context) |
void |
SimpleSubscribeResponseHandler.asyncCloseSubscription(TopicSubscriber topicSubscriber,
Callback<PubSubProtocol.ResponseBody> callback,
Object context) |
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) |
SubscribeResponseHandler |
SimpleHChannelManager.getSubscribeResponseHandler(TopicSubscriber topicSubscriber) |
protected HChannel |
SimpleHChannelManager.getSubscriptionChannelByTopicSubscriber(TopicSubscriber subscriber) |
protected Either<PubSubProtocol.StatusCode,HChannel> |
SimpleSubscribeResponseHandler.handleSuccessResponse(TopicSubscriber ts,
PubSubData pubSubData,
org.jboss.netty.channel.Channel channel) |
boolean |
SimpleSubscribeResponseHandler.hasSubscription(TopicSubscriber ts) |
protected void |
SimpleSubscribeResponseHandler.postHandleSuccessResponse(TopicSubscriber ts,
ActiveSubscriber as) |
protected boolean |
SimpleSubscribeResponseHandler.removeSubscription(TopicSubscriber ts,
ActiveSubscriber ss) |
protected void |
SimpleHChannelManager.restartDelivery(TopicSubscriber topicSubscriber) |
void |
SimpleHChannelManager.startDelivery(TopicSubscriber topicSubscriber,
MessageHandler messageHandler) |
void |
SimpleHChannelManager.stopDelivery(TopicSubscriber topicSubscriber) |
protected Either<Boolean,HChannel> |
SimpleHChannelManager.storeSubscriptionChannel(TopicSubscriber topicSubscriber,
PubSubData txn,
org.jboss.netty.channel.Channel channel) |
Copyright © 2015 The Apache Software Foundation. All rights reserved.