| Package | Description |
|---|---|
| org.apache.hedwig.client.netty.impl | |
| org.apache.hedwig.client.netty.impl.multiplex | |
| org.apache.hedwig.client.netty.impl.simple | |
| org.apache.hedwig.util |
| 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 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 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 |
|---|---|
static <T,U> Either<T,U> |
Either.left(T x) |
static <T,U> Either<T,U> |
Either.of(T x,
U y) |
static <T,U> Either<T,U> |
Either.right(U y) |
Copyright © 2011–2021 The Apache Software Foundation. All rights reserved.