Package de.unistuttgart.isw.sfsc.commonjava.zmq.pubsubsocketpair.inputmanagement.subscription

Interface SubscriptionTracker

All Known Implementing Classes:

SubscriptionTrackingInbox

public interface SubscriptionTracker

Method Summary

Modifier and Type	Method	Description
Handle	addListener(Consumer<StoreEvent<com.google.protobuf.ByteString>> listener)
Future<Void>	addOneShotListener(Predicate<StoreEvent<com.google.protobuf.ByteString>> predicate, Runnable runnable)
Future<Void>	addOneShotSubscriptionListener(com.google.protobuf.ByteString topic, Runnable runnable)
Set<com.google.protobuf.ByteString>	getSubscriptions()

Method Detail

getSubscriptions

Set<com.google.protobuf.ByteString> getSubscriptions()

addListener

Handle addListener(Consumer<StoreEvent<com.google.protobuf.ByteString>> listener)

addOneShotListener

Future<Void> addOneShotListener(Predicate<StoreEvent<com.google.protobuf.ByteString>> predicate,
                                Runnable runnable)

addOneShotSubscriptionListener

Future<Void> addOneShotSubscriptionListener(com.google.protobuf.ByteString topic,
                                            Runnable runnable)