| Package | Description |
|---|---|
| org.apache.hedwig.client.api |
| Modifier and Type | Method and Description |
|---|---|
void |
Subscriber.closeSubscription(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId)
Closes all of the client side cached data for this subscription without
actually sending an unsubscribe request to the server.
|
List<com.google.protobuf.ByteString> |
Subscriber.getSubscriptionList(com.google.protobuf.ByteString subscriberId)
Fills the input List with the subscriptions this subscriberId client is
subscribed to.
|
boolean |
Subscriber.hasSubscription(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId)
Checks if the subscriberId client is currently subscribed to the given
topic.
|
PubSubProtocol.PublishResponse |
Publisher.publish(com.google.protobuf.ByteString topic,
PubSubProtocol.Message msg)
Publishes a message on the given topic.
|
void |
Subscriber.subscribe(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.SubscribeRequest.CreateOrAttach mode)
Deprecated.
As of BookKeeper 4.2.0, replaced by
Subscriber.subscribe(com.google.protobuf.ByteString,
com.google.protobuf.ByteString,
PubSubProtocol.SubscriptionOptions) |
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.
|
void |
Subscriber.unsubscribe(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId)
Unsubscribe from a topic that the subscriberId user has previously
subscribed to.
|
Copyright © 2011-2014 The Apache Software Foundation. All Rights Reserved.