org.apache.hedwig.client.api

Interface MessageHandler

public interface MessageHandler

Interface to define the client handler logic to deliver messages it is subscribed to.

Method Summary

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.

Method Detail

deliver

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.

Parameters:

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.