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.multiplex | |
org.apache.hedwig.client.netty.impl.simple | |
org.apache.hedwig.util |
Modifier and Type | Method and Description |
---|---|
void |
Subscriber.asyncCloseSubscription(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
Callback<Void> callback,
Object context)
Closes all of the client side cached data for this subscription without
actually sending an unsubscribe request to the server.
|
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 |
Subscriber.asyncSubscribe(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.SubscribeRequest.CreateOrAttach mode,
Callback<Void> callback,
Object context)
Deprecated.
As of BookKeeper 4.2.0, replaced by
Subscriber.asyncSubscribe(com.google.protobuf.ByteString,
com.google.protobuf.ByteString,
PubSubProtocol.SubscriptionOptions,Callback,Object) |
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.asyncUnsubscribe(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
Callback<Void> callback,
Object context)
Unsubscribe from a topic asynchronously that the subscriberId user has
previously subscribed to.
|
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.
|
Modifier and Type | Class and Description |
---|---|
static class |
BenchmarkUtils.BenchmarkCallback |
Modifier and Type | Method and Description |
---|---|
Callback<PubSubProtocol.ResponseBody> |
PubSubData.getCallback() |
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 | Class and Description |
---|---|
class |
MessageConsumeCallback
This is the Callback used by the MessageHandlers on the client app when
they've finished consuming a subscription message sent from the server
asynchronously.
|
class |
PubSubCallback
This class is used when we are doing synchronous type of operations.
|
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 | Class and Description |
---|---|
class |
VoidCallbackAdapter<T>
Adapts from Callback<T> to Callback<Void>.
|
Modifier and Type | Method and Description |
---|---|
void |
HedwigSubscriber.asyncCloseSubscription(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
Callback<Void> callback,
Object context) |
void |
HChannelManager.asyncCloseSubscription(TopicSubscriber topicSubscriber,
Callback<PubSubProtocol.ResponseBody> callback,
Object context)
Close the subscription of the given
topicSubscriber . |
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 |
HedwigSubscriber.asyncSubscribe(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.SubscribeRequest.CreateOrAttach mode,
Callback<Void> callback,
Object context) |
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.asyncUnsubscribe(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
Callback<Void> callback,
Object context) |
protected void |
HedwigSubscriber.asyncUnsubscribe(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
Callback<Void> callback,
Object context,
boolean isHub) |
void |
FilterableMessageHandler.deliver(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.Message msg,
Callback<Void> callback,
Object context) |
Constructor and Description |
---|
VoidCallbackAdapter(Callback<Void> delegate) |
Modifier and Type | Method and Description |
---|---|
void |
MultiplexHChannelManager.asyncCloseSubscription(TopicSubscriber topicSubscriber,
Callback<PubSubProtocol.ResponseBody> callback,
Object context) |
void |
MultiplexSubscribeResponseHandler.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 | Method and Description |
---|---|
static <T> Callback<Void> |
CallbackUtils.curry(Callback<T> cb,
T result)
Return a Callback
|
static Callback<Void> |
CallbackUtils.logger(org.slf4j.Logger logger,
String successMsg,
String failureMsg)
Logs what happened (no continuation).
|
static <T> Callback<T> |
CallbackUtils.logger(org.slf4j.Logger logger,
String successMsg,
String failureMsg,
Callback<T> cont)
Logs what happened before continuing the callback chain.
|
static Callback<Void> |
CallbackUtils.multiCallback(int expected,
Callback<Void> cb,
Object ctx)
A callback that waits for all of a number of events to fire.
|
static Callback<Void> |
CallbackUtils.multiCallback(int expected,
Callback<Void> cb,
Object ctx,
org.slf4j.Logger logger,
String successMsg,
String failureMsg,
Runnable eagerErrorHandler)
A callback that waits for all of a number of events to fire.
|
static Callback<Void> |
CallbackUtils.multinCallback(int expected,
Callback<Void> cb,
Object ctx,
Runnable eagerErrorHandler)
A callback that waits for all of a number of events to fire.
|
static Callback<Void> |
CallbackUtils.nop()
A do-nothing callback.
|
Modifier and Type | Method and Description |
---|---|
static <T> Callback<Void> |
CallbackUtils.curry(Callback<T> cb,
T result)
Return a Callback
|
static <T> Callback<T> |
CallbackUtils.logger(org.slf4j.Logger logger,
String successMsg,
String failureMsg,
Callback<T> cont)
Logs what happened before continuing the callback chain.
|
static Callback<Void> |
CallbackUtils.multiCallback(int expected,
Callback<Void> cb,
Object ctx)
A callback that waits for all of a number of events to fire.
|
static Callback<Void> |
CallbackUtils.multiCallback(int expected,
Callback<Void> cb,
Object ctx,
org.slf4j.Logger logger,
String successMsg,
String failureMsg,
Runnable eagerErrorHandler)
A callback that waits for all of a number of events to fire.
|
static Callback<Void> |
CallbackUtils.multinCallback(int expected,
Callback<Void> cb,
Object ctx,
Runnable eagerErrorHandler)
A callback that waits for all of a number of events to fire.
|
Copyright © 2011–2017 The Apache Software Foundation. All rights reserved.