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 © 2015 The Apache Software Foundation. All rights reserved.