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) |
abstract void |
SubscribeResponseHandler.handleSubscribeMessage(PubSubProtocol.PubSubResponse response)
Handle Message delivered by the server.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractSubscribeResponseHandler.handleResponse(PubSubProtocol.PubSubResponse response,
PubSubData pubSubData,
org.jboss.netty.channel.Channel channel) |
void |
AbstractSubscribeResponseHandler.handleSubscribeMessage(PubSubProtocol.PubSubResponse response) |
Modifier and Type | Method and Description |
---|---|
void |
MultiplexSubscribeResponseHandler.handleResponse(PubSubProtocol.PubSubResponse response,
PubSubData pubSubData,
org.jboss.netty.channel.Channel channel) |
Modifier and Type | Method and Description |
---|---|
void |
SimpleSubscribeResponseHandler.handleResponse(PubSubProtocol.PubSubResponse response,
PubSubData pubSubData,
org.jboss.netty.channel.Channel channel) |
void |
SimpleSubscribeResponseHandler.handleSubscribeMessage(PubSubProtocol.PubSubResponse response) |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<PubSubProtocol.PubSubResponse> |
PubSubProtocol.PubSubResponse.PARSER |
Modifier and Type | Method and Description |
---|---|
PubSubProtocol.PubSubResponse |
PubSubProtocol.PubSubResponse.Builder.build() |
PubSubProtocol.PubSubResponse |
PubSubProtocol.PubSubResponse.Builder.buildPartial() |
static PubSubProtocol.PubSubResponse |
PubSubProtocol.PubSubResponse.getDefaultInstance() |
PubSubProtocol.PubSubResponse |
PubSubProtocol.PubSubResponse.getDefaultInstanceForType() |
PubSubProtocol.PubSubResponse |
PubSubProtocol.PubSubResponse.Builder.getDefaultInstanceForType() |
static PubSubProtocol.PubSubResponse |
PubSubProtocol.PubSubResponse.parseDelimitedFrom(InputStream input) |
static PubSubProtocol.PubSubResponse |
PubSubProtocol.PubSubResponse.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.PubSubResponse |
PubSubProtocol.PubSubResponse.parseFrom(byte[] data) |
static PubSubProtocol.PubSubResponse |
PubSubProtocol.PubSubResponse.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.PubSubResponse |
PubSubProtocol.PubSubResponse.parseFrom(com.google.protobuf.ByteString data) |
static PubSubProtocol.PubSubResponse |
PubSubProtocol.PubSubResponse.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.PubSubResponse |
PubSubProtocol.PubSubResponse.parseFrom(com.google.protobuf.CodedInputStream input) |
static PubSubProtocol.PubSubResponse |
PubSubProtocol.PubSubResponse.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.PubSubResponse |
PubSubProtocol.PubSubResponse.parseFrom(InputStream input) |
static PubSubProtocol.PubSubResponse |
PubSubProtocol.PubSubResponse.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<PubSubProtocol.PubSubResponse> |
PubSubProtocol.PubSubResponse.getParserForType() |
Modifier and Type | Method and Description |
---|---|
PubSubProtocol.PubSubResponse.Builder |
PubSubProtocol.PubSubResponse.Builder.mergeFrom(PubSubProtocol.PubSubResponse other) |
static PubSubProtocol.PubSubResponse.Builder |
PubSubProtocol.PubSubResponse.newBuilder(PubSubProtocol.PubSubResponse prototype) |
Copyright © 2011–2016 The Apache Software Foundation. All rights reserved.