Package | Description |
---|---|
org.apache.hedwig.client.api | |
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 | 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-2014 The Apache Software Foundation. All Rights Reserved.