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.multiplex | |
org.apache.hedwig.client.netty.impl.simple | |
org.apache.hedwig.protocol |
Modifier and Type | Method and Description |
---|---|
Callback<PubSubProtocol.ResponseBody> |
PubSubData.getCallback() |
Modifier and Type | Method and Description |
---|---|
void |
PubSubData.operationFinishedToCallback(Object context,
PubSubProtocol.ResponseBody response) |
Modifier and Type | Method and Description |
---|---|
void |
PubSubData.setCallback(Callback<PubSubProtocol.ResponseBody> callback) |
Constructor and Description |
---|
PubSubData(com.google.protobuf.ByteString topic,
PubSubProtocol.Message msg,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.OperationType operationType,
PubSubProtocol.SubscriptionOptions options,
Callback<PubSubProtocol.ResponseBody> callback,
Object context) |
Modifier and Type | Method and Description |
---|---|
PubSubProtocol.ResponseBody |
PubSubCallback.getResponseBody() |
Modifier and Type | Method and Description |
---|---|
void |
PubSubCallback.operationFinished(Object ctx,
PubSubProtocol.ResponseBody resultOfOperation) |
Modifier and Type | Method and Description |
---|---|
abstract void |
SubscribeResponseHandler.asyncCloseSubscription(TopicSubscriber topicSubscriber,
Callback<PubSubProtocol.ResponseBody> callback,
Object context)
Close subscription from this handler.
|
Modifier and Type | Method and Description |
---|---|
void |
HChannelManager.asyncCloseSubscription(TopicSubscriber topicSubscriber,
Callback<PubSubProtocol.ResponseBody> callback,
Object context)
Close the subscription of the given
topicSubscriber . |
Modifier and Type | Method and Description |
---|---|
void |
MultiplexSubscribeResponseHandler.asyncCloseSubscription(TopicSubscriber topicSubscriber,
Callback<PubSubProtocol.ResponseBody> callback,
Object context) |
void |
MultiplexHChannelManager.asyncCloseSubscription(TopicSubscriber topicSubscriber,
Callback<PubSubProtocol.ResponseBody> callback,
Object context) |
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) |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<PubSubProtocol.ResponseBody> |
PubSubProtocol.ResponseBody.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
PubSubProtocol.ResponseBody |
PubSubProtocol.ResponseBody.Builder.build() |
PubSubProtocol.ResponseBody |
PubSubProtocol.ResponseBody.Builder.buildPartial() |
static PubSubProtocol.ResponseBody |
PubSubProtocol.ResponseBody.getDefaultInstance() |
PubSubProtocol.ResponseBody |
PubSubProtocol.ResponseBody.getDefaultInstanceForType() |
PubSubProtocol.ResponseBody |
PubSubProtocol.ResponseBody.Builder.getDefaultInstanceForType() |
PubSubProtocol.ResponseBody |
PubSubProtocol.PubSubResponseOrBuilder.getResponseBody()
the following fields are sent by other requests
|
PubSubProtocol.ResponseBody |
PubSubProtocol.PubSubResponse.getResponseBody()
the following fields are sent by other requests
|
PubSubProtocol.ResponseBody |
PubSubProtocol.PubSubResponse.Builder.getResponseBody()
the following fields are sent by other requests
|
static PubSubProtocol.ResponseBody |
PubSubProtocol.ResponseBody.parseDelimitedFrom(InputStream input) |
static PubSubProtocol.ResponseBody |
PubSubProtocol.ResponseBody.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.ResponseBody |
PubSubProtocol.ResponseBody.parseFrom(byte[] data) |
static PubSubProtocol.ResponseBody |
PubSubProtocol.ResponseBody.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.ResponseBody |
PubSubProtocol.ResponseBody.parseFrom(ByteBuffer data) |
static PubSubProtocol.ResponseBody |
PubSubProtocol.ResponseBody.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.ResponseBody |
PubSubProtocol.ResponseBody.parseFrom(com.google.protobuf.ByteString data) |
static PubSubProtocol.ResponseBody |
PubSubProtocol.ResponseBody.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.ResponseBody |
PubSubProtocol.ResponseBody.parseFrom(com.google.protobuf.CodedInputStream input) |
static PubSubProtocol.ResponseBody |
PubSubProtocol.ResponseBody.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.ResponseBody |
PubSubProtocol.ResponseBody.parseFrom(InputStream input) |
static PubSubProtocol.ResponseBody |
PubSubProtocol.ResponseBody.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<PubSubProtocol.ResponseBody> |
PubSubProtocol.ResponseBody.getParserForType() |
static com.google.protobuf.Parser<PubSubProtocol.ResponseBody> |
PubSubProtocol.ResponseBody.parser() |
Modifier and Type | Method and Description |
---|---|
PubSubProtocol.ResponseBody.Builder |
PubSubProtocol.ResponseBody.Builder.mergeFrom(PubSubProtocol.ResponseBody other) |
PubSubProtocol.PubSubResponse.Builder |
PubSubProtocol.PubSubResponse.Builder.mergeResponseBody(PubSubProtocol.ResponseBody value)
the following fields are sent by other requests
|
static PubSubProtocol.ResponseBody.Builder |
PubSubProtocol.ResponseBody.newBuilder(PubSubProtocol.ResponseBody prototype) |
PubSubProtocol.PubSubResponse.Builder |
PubSubProtocol.PubSubResponse.Builder.setResponseBody(PubSubProtocol.ResponseBody value)
the following fields are sent by other requests
|
Copyright © 2011–2018 The Apache Software Foundation. All rights reserved.