Package | Description |
---|---|
org.apache.hedwig.client.api | |
org.apache.hedwig.client.data | |
org.apache.hedwig.client.netty |
A Netty based Hedwig client implementation.
|
org.apache.hedwig.protocol |
Modifier and Type | Method and Description |
---|---|
void |
Subscriber.asyncSubscribe(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.SubscriptionOptions options,
Callback<Void> callback,
Object context)
Subscribe to the given topic asynchronously for the inputted subscriberId.
|
void |
Subscriber.subscribe(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.SubscriptionOptions options)
Subscribe to the given topic for the inputted subscriberId.
|
Modifier and Type | Field and Description |
---|---|
PubSubProtocol.SubscriptionOptions |
PubSubData.options |
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 |
---|---|
void |
HedwigSubscriber.asyncSubscribe(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.SubscriptionOptions options,
Callback<Void> callback,
Object context) |
protected void |
HedwigSubscriber.asyncSubscribe(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.SubscriptionOptions options,
Callback<Void> callback,
Object context,
boolean isHub) |
void |
HedwigSubscriber.subscribe(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.SubscriptionOptions options) |
protected void |
HedwigSubscriber.subscribe(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.SubscriptionOptions options,
boolean isHub) |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<PubSubProtocol.SubscriptionOptions> |
PubSubProtocol.SubscriptionOptions.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
PubSubProtocol.SubscriptionOptions |
PubSubProtocol.SubscriptionOptions.Builder.build() |
PubSubProtocol.SubscriptionOptions |
PubSubProtocol.SubscriptionOptions.Builder.buildPartial() |
static PubSubProtocol.SubscriptionOptions |
PubSubProtocol.SubscriptionOptions.getDefaultInstance() |
PubSubProtocol.SubscriptionOptions |
PubSubProtocol.SubscriptionOptions.getDefaultInstanceForType() |
PubSubProtocol.SubscriptionOptions |
PubSubProtocol.SubscriptionOptions.Builder.getDefaultInstanceForType() |
static PubSubProtocol.SubscriptionOptions |
PubSubProtocol.SubscriptionOptions.parseDelimitedFrom(InputStream input) |
static PubSubProtocol.SubscriptionOptions |
PubSubProtocol.SubscriptionOptions.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.SubscriptionOptions |
PubSubProtocol.SubscriptionOptions.parseFrom(byte[] data) |
static PubSubProtocol.SubscriptionOptions |
PubSubProtocol.SubscriptionOptions.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.SubscriptionOptions |
PubSubProtocol.SubscriptionOptions.parseFrom(ByteBuffer data) |
static PubSubProtocol.SubscriptionOptions |
PubSubProtocol.SubscriptionOptions.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.SubscriptionOptions |
PubSubProtocol.SubscriptionOptions.parseFrom(com.google.protobuf.ByteString data) |
static PubSubProtocol.SubscriptionOptions |
PubSubProtocol.SubscriptionOptions.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.SubscriptionOptions |
PubSubProtocol.SubscriptionOptions.parseFrom(com.google.protobuf.CodedInputStream input) |
static PubSubProtocol.SubscriptionOptions |
PubSubProtocol.SubscriptionOptions.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.SubscriptionOptions |
PubSubProtocol.SubscriptionOptions.parseFrom(InputStream input) |
static PubSubProtocol.SubscriptionOptions |
PubSubProtocol.SubscriptionOptions.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<PubSubProtocol.SubscriptionOptions> |
PubSubProtocol.SubscriptionOptions.getParserForType() |
static com.google.protobuf.Parser<PubSubProtocol.SubscriptionOptions> |
PubSubProtocol.SubscriptionOptions.parser() |
Modifier and Type | Method and Description |
---|---|
PubSubProtocol.SubscriptionOptions.Builder |
PubSubProtocol.SubscriptionOptions.Builder.mergeFrom(PubSubProtocol.SubscriptionOptions other) |
static PubSubProtocol.SubscriptionOptions.Builder |
PubSubProtocol.SubscriptionOptions.newBuilder(PubSubProtocol.SubscriptionOptions prototype) |
Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.