| 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 |
SimpleSubscribeResponseHandler.asyncCloseSubscription(TopicSubscriber topicSubscriber,
Callback<PubSubProtocol.ResponseBody> callback,
Object context) |
void |
SimpleHChannelManager.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–2021 The Apache Software Foundation. All rights reserved.