Package | Description |
---|---|
org.apache.hedwig.client.api | |
org.apache.hedwig.client.benchmark | |
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 | |
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 |
BenchmarkPublisher.getMsg(int size) |
Modifier and Type | Field and Description |
---|---|
PubSubProtocol.Message |
MessageConsumeData.msg |
PubSubProtocol.Message |
PubSubData.msg |
Constructor and Description |
---|
MessageConsumeData(TopicSubscriber topicSubscriber,
PubSubProtocol.Message msg) |
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 |
---|---|
protected abstract void |
SubscribeResponseHandler.asyncMessageDeliver(TopicSubscriber topicSubscriber,
PubSubProtocol.Message message)
Method called when a message arrives for a subscribe Channel and we want
to deliver it asynchronously via the registered MessageHandler (should
not be null when called here).
|
protected abstract void |
SubscribeResponseHandler.messageConsumed(TopicSubscriber topicSubscriber,
PubSubProtocol.Message message)
Method called when the client app's MessageHandler has asynchronously
completed consuming a subscribed message sent from the server.
|
Modifier and Type | Method and Description |
---|---|
void |
HedwigPublisher.asyncPublish(com.google.protobuf.ByteString topic,
PubSubProtocol.Message msg,
Callback<Void> callback,
Object context) |
void |
HedwigPublisher.asyncPublishWithResponse(com.google.protobuf.ByteString topic,
PubSubProtocol.Message msg,
Callback<PubSubProtocol.PublishResponse> callback,
Object context) |
void |
FilterableMessageHandler.deliver(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.Message msg,
Callback<Void> callback,
Object context) |
PubSubProtocol.PublishResponse |
HedwigPublisher.publish(com.google.protobuf.ByteString topic,
PubSubProtocol.Message msg) |
Modifier and Type | Method and Description |
---|---|
void |
ActiveSubscriber.asyncMessageDeliver(PubSubProtocol.Message message)
Deliver message to the client.
|
protected void |
AbstractSubscribeResponseHandler.asyncMessageDeliver(TopicSubscriber topicSubscriber,
PubSubProtocol.Message message) |
void |
ActiveSubscriber.handleMessage(PubSubProtocol.Message message)
Handle received message.
|
void |
ActiveSubscriber.messageConsumed(PubSubProtocol.Message message)
Application acked to consume message.
|
protected void |
AbstractSubscribeResponseHandler.messageConsumed(TopicSubscriber topicSubscriber,
PubSubProtocol.Message message) |
protected void |
ActiveSubscriber.unsafeDeliverMessage(PubSubProtocol.Message message)
Unsafe version to deliver message to a message handler.
|
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<PubSubProtocol.Message> |
PubSubProtocol.Message.PARSER
Deprecated.
|
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()
the following fields are sent in delivered messages
|
PubSubProtocol.Message |
PubSubProtocol.PubSubResponse.getMessage()
the following fields are sent in delivered messages
|
PubSubProtocol.Message |
PubSubProtocol.PubSubResponse.Builder.getMessage()
the following fields are sent in delivered messages
|
PubSubProtocol.Message |
PubSubProtocol.PublishRequestOrBuilder.getMsg()
required .Hedwig.Message msg = 2; |
PubSubProtocol.Message |
PubSubProtocol.PublishRequest.getMsg()
required .Hedwig.Message msg = 2; |
PubSubProtocol.Message |
PubSubProtocol.PublishRequest.Builder.getMsg()
required .Hedwig.Message msg = 2; |
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(ByteBuffer data) |
static PubSubProtocol.Message |
PubSubProtocol.Message.parseFrom(ByteBuffer 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 |
---|---|
com.google.protobuf.Parser<PubSubProtocol.Message> |
PubSubProtocol.Message.getParserForType() |
static com.google.protobuf.Parser<PubSubProtocol.Message> |
PubSubProtocol.Message.parser() |
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)
the following fields are sent in delivered messages
|
PubSubProtocol.PublishRequest.Builder |
PubSubProtocol.PublishRequest.Builder.mergeMsg(PubSubProtocol.Message value)
required .Hedwig.Message msg = 2; |
static PubSubProtocol.Message.Builder |
PubSubProtocol.Message.newBuilder(PubSubProtocol.Message prototype) |
PubSubProtocol.PubSubResponse.Builder |
PubSubProtocol.PubSubResponse.Builder.setMessage(PubSubProtocol.Message value)
the following fields are sent in delivered messages
|
PubSubProtocol.PublishRequest.Builder |
PubSubProtocol.PublishRequest.Builder.setMsg(PubSubProtocol.Message value)
required .Hedwig.Message msg = 2; |
Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.