Package | Description |
---|---|
org.apache.hedwig.client.api |
Modifier and Type | Method and Description |
---|---|
void |
Subscriber.consume(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
PubSubProtocol.MessageSeqId messageSeqId)
Manually send a consume message to the server for the given inputs.
|
void |
Subscriber.startDelivery(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
MessageHandler messageHandler)
Begin delivery of messages from the server to us for this topic and
subscriberId.
|
void |
Subscriber.startDeliveryWithFilter(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId,
MessageHandler messageHandler,
org.apache.hedwig.filter.ClientMessageFilter messageFilter)
Begin delivery of messages from the server to us for this topic and
subscriberId.
|
void |
Subscriber.stopDelivery(com.google.protobuf.ByteString topic,
com.google.protobuf.ByteString subscriberId)
Stop delivery of messages for this topic and 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.