| Package | Description |
|---|---|
| org.apache.hedwig.client.api | |
| org.apache.hedwig.protocol |
| Modifier and Type | Method and Description |
|---|---|
void |
Publisher.asyncPublish(com.google.protobuf.ByteString topic,
PubSubProtocol.Message msg,
Callback<Void> callback,
Object context)
Publishes a message asynchronously on the given topic.
|
void |
Publisher.asyncPublishWithResponse(com.google.protobuf.ByteString topic,
PubSubProtocol.Message msg,
Callback<PubSubProtocol.PublishResponse> callback,
Object context)
Publishes a message asynchronously on the given topic.
|
void |
MessageHandler.deliver(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.Message msg,
Callback<Void> callback,
Object context)
Delivers a message which has been published for topic.
|
PubSubProtocol.PublishResponse |
Publisher.publish(com.google.protobuf.ByteString topic,
PubSubProtocol.Message msg)
Publishes a message on the given topic.
|
| Modifier and Type | Method and Description |
|---|---|
PubSubProtocol.Message |
PubSubProtocol.Message.Builder.build() |
PubSubProtocol.Message |
PubSubProtocol.Message.Builder.buildPartial() |
static PubSubProtocol.Message |
PubSubProtocol.Message.getDefaultInstance() |
PubSubProtocol.Message |
PubSubProtocol.Message.getDefaultInstanceForType() |
PubSubProtocol.Message |
PubSubProtocol.Message.Builder.getDefaultInstanceForType() |
PubSubProtocol.Message |
PubSubProtocol.PubSubResponseOrBuilder.getMessage() |
PubSubProtocol.Message |
PubSubProtocol.PubSubResponse.getMessage() |
PubSubProtocol.Message |
PubSubProtocol.PubSubResponse.Builder.getMessage() |
PubSubProtocol.Message |
PubSubProtocol.PublishRequestOrBuilder.getMsg() |
PubSubProtocol.Message |
PubSubProtocol.PublishRequest.getMsg() |
PubSubProtocol.Message |
PubSubProtocol.PublishRequest.Builder.getMsg() |
static PubSubProtocol.Message |
PubSubProtocol.Message.parseDelimitedFrom(InputStream input) |
static PubSubProtocol.Message |
PubSubProtocol.Message.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.Message |
PubSubProtocol.Message.parseFrom(byte[] data) |
static PubSubProtocol.Message |
PubSubProtocol.Message.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.Message |
PubSubProtocol.Message.parseFrom(com.google.protobuf.ByteString data) |
static PubSubProtocol.Message |
PubSubProtocol.Message.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.Message |
PubSubProtocol.Message.parseFrom(com.google.protobuf.CodedInputStream input) |
static PubSubProtocol.Message |
PubSubProtocol.Message.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static PubSubProtocol.Message |
PubSubProtocol.Message.parseFrom(InputStream input) |
static PubSubProtocol.Message |
PubSubProtocol.Message.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
| Modifier and Type | Method and Description |
|---|---|
PubSubProtocol.Message.Builder |
PubSubProtocol.Message.Builder.mergeFrom(PubSubProtocol.Message other) |
PubSubProtocol.PubSubResponse.Builder |
PubSubProtocol.PubSubResponse.Builder.mergeMessage(PubSubProtocol.Message value) |
PubSubProtocol.PublishRequest.Builder |
PubSubProtocol.PublishRequest.Builder.mergeMsg(PubSubProtocol.Message value) |
static PubSubProtocol.Message.Builder |
PubSubProtocol.Message.newBuilder(PubSubProtocol.Message prototype) |
PubSubProtocol.PubSubResponse.Builder |
PubSubProtocol.PubSubResponse.Builder.setMessage(PubSubProtocol.Message value) |
PubSubProtocol.PublishRequest.Builder |
PubSubProtocol.PublishRequest.Builder.setMsg(PubSubProtocol.Message value) |
Copyright © 2011-2014 The Apache Software Foundation. All Rights Reserved.