org.apache.hedwig.util

Interface SubscriptionListener

public interface SubscriptionListener

This class is used for subscriber to listen on subscription event.

Method Summary

Modifier and Type	Method and Description
void	processEvent(com.google.protobuf.ByteString topic, com.google.protobuf.ByteString subscriberId, PubSubProtocol.SubscriptionEvent event) Process an event from a subscription.

Method Detail

processEvent

void processEvent(com.google.protobuf.ByteString topic,
                  com.google.protobuf.ByteString subscriberId,
                  PubSubProtocol.SubscriptionEvent event)

Process an event from a subscription.

NOTE: It would be better to not run blocking operations in a listener implementation.

Parameters:

topic - Topic Name

subscriberId - Subscriber Id

event - Event tell what happened to the subscription.