Package | Description |
---|---|
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 | Method and Description |
---|---|
protected void |
AbstractResponseHandler.handleRedirectResponse(PubSubProtocol.PubSubResponse response,
PubSubData pubSubData,
org.jboss.netty.channel.Channel channel)
Logic to repost a PubSubRequest when the server responds with a redirect
indicating they are not the topic master.
|
abstract void |
AbstractResponseHandler.handleResponse(PubSubProtocol.PubSubResponse response,
PubSubData pubSubData,
org.jboss.netty.channel.Channel channel)
Logic to handle received response.
|
void |
UnsubscribeResponseHandler.handleResponse(PubSubProtocol.PubSubResponse response,
PubSubData pubSubData,
org.jboss.netty.channel.Channel channel) |
void |
CloseSubscriptionResponseHandler.handleResponse(PubSubProtocol.PubSubResponse response,
PubSubData pubSubData,
org.jboss.netty.channel.Channel channel) |
void |
PublishResponseHandler.handleResponse(PubSubProtocol.PubSubResponse response,
PubSubData pubSubData,
org.jboss.netty.channel.Channel channel) |
Constructor and Description |
---|
PubSubCallback(PubSubData pubSubData) |
Modifier and Type | Method and Description |
---|---|
static PubSubProtocol.PubSubRequest.Builder |
NetUtils.buildPubSubRequest(long txnId,
PubSubData pubSubData)
This is a helper method to build the actual pub/sub message.
|
void |
HChannelManager.redirectToHost(PubSubData pubSubData,
InetSocketAddress host)
Submit a pub/sub request to a given host.
|
void |
HChannelManager.submitOp(PubSubData pubSubData)
Submit a pub/sub request.
|
void |
HChannel.submitOp(PubSubData op)
Submit a pub/sub request.
|
void |
HChannelManager.submitOpAfterDelay(PubSubData op,
long delay)
Submit a pub/sub request after a given
delay . |
void |
HChannelManager.submitOpToDefaultServer(PubSubData pubSubData)
Submit a pub/sub request to default server.
|
Modifier and Type | Field and Description |
---|---|
protected PubSubData |
ActiveSubscriber.op |
Modifier and Type | Method and Description |
---|---|
PubSubData |
ActiveSubscriber.getPubSubData() |
Modifier and Type | Method and Description |
---|---|
void |
HChannelHandler.addTxn(long txnId,
PubSubData pubSubData) |
protected ActiveSubscriber |
AbstractSubscribeResponseHandler.createActiveSubscriber(ClientConfiguration cfg,
AbstractHChannelManager channelManager,
TopicSubscriber ts,
PubSubData op,
PubSubProtocol.SubscriptionPreferences preferences,
org.jboss.netty.channel.Channel channel,
HChannel hChannel) |
void |
AbstractSubscribeResponseHandler.handleResponse(PubSubProtocol.PubSubResponse response,
PubSubData pubSubData,
org.jboss.netty.channel.Channel channel) |
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 . |
void |
AbstractHChannelManager.redirectToHost(PubSubData pubSubData,
InetSocketAddress host) |
protected void |
HChannelImpl.retryOrFailOp(PubSubData pubSubData)
Re-submit operation to default server or fail it.
|
void |
AbstractHChannelManager.submitOp(PubSubData pubSubData) |
void |
HChannelImpl.submitOp(PubSubData pubSubData) |
void |
AbstractHChannelManager.submitOpAfterDelay(PubSubData pubSubData,
long delay) |
void |
AbstractHChannelManager.submitOpToDefaultServer(PubSubData pubSubData) |
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.
|
WriteCallback(PubSubData pubSubData,
HChannelManager channelManager) |
Modifier and Type | Method and Description |
---|---|
void |
MultiplexSubscribeResponseHandler.handleResponse(PubSubProtocol.PubSubResponse response,
PubSubData pubSubData,
org.jboss.netty.channel.Channel channel) |
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 ActiveSubscriber |
SimpleSubscribeResponseHandler.createActiveSubscriber(ClientConfiguration cfg,
AbstractHChannelManager channelManager,
TopicSubscriber ts,
PubSubData op,
PubSubProtocol.SubscriptionPreferences preferences,
org.jboss.netty.channel.Channel channel,
HChannel hChannel) |
void |
SimpleSubscribeResponseHandler.handleResponse(PubSubProtocol.PubSubResponse response,
PubSubData pubSubData,
org.jboss.netty.channel.Channel channel) |
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) |
void |
SimpleHChannelManager.submitOp(PubSubData pubSubData) |
Copyright © 2011–2018 The Apache Software Foundation. All rights reserved.