public interface MessageHandler
Modifier and Type | Method and Description |
---|---|
void |
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.
|
void deliver(com.google.protobuf.ByteString topic, com.google.protobuf.ByteString subscriberId, PubSubProtocol.Message msg, Callback<Void> callback, Object context)
topic
- The topic name where the message came from.subscriberId
- ID of the subscriber.msg
- The message object to deliver.callback
- Callback to invoke when the message delivery has been done.context
- Calling context that the Callback needs since this is done
asynchronously.Copyright © 2011-2014 The Apache Software Foundation. All Rights Reserved.