Uses of Interface
de.unistuttgart.isw.sfsc.commonjava.util.Handle

Packages that use Handle

Package	Description
de.unistuttgart.isw.sfsc.commonjava.util
de.unistuttgart.isw.sfsc.commonjava.zmq.pubsubsocketpair.inputmanagement.data
de.unistuttgart.isw.sfsc.commonjava.zmq.pubsubsocketpair.inputmanagement.forwarder
de.unistuttgart.isw.sfsc.commonjava.zmq.pubsubsocketpair.inputmanagement.subscription
de.unistuttgart.isw.sfsc.commonjava.zmq.pubsubsocketpair.outputmanagement
de.unistuttgart.isw.sfsc.commonjava.zmq.reactor
de.unistuttgart.isw.sfsc.commonjava.zmq.util

Uses of Handle in de.unistuttgart.isw.sfsc.commonjava.util

Methods in de.unistuttgart.isw.sfsc.commonjava.util that return Handle

Modifier and Type	Method	Description
Handle	Listeners.add(T entry)

Methods in de.unistuttgart.isw.sfsc.commonjava.util with parameters of type Handle

Modifier and Type	Method	Description
Future<Void>	OneShotListener.initialize(Handle handle)

Uses of Handle in de.unistuttgart.isw.sfsc.commonjava.zmq.pubsubsocketpair.inputmanagement.data

Methods in de.unistuttgart.isw.sfsc.commonjava.zmq.pubsubsocketpair.inputmanagement.data that return Handle

Modifier and Type	Method	Description
Handle	DataMultiplexer.add(Predicate<com.google.protobuf.ByteString> filter, BiConsumer<com.google.protobuf.ByteString,com.google.protobuf.ByteString> handler)
Handle	DataMultiplexingInbox.add(Predicate<com.google.protobuf.ByteString> filter, BiConsumer<com.google.protobuf.ByteString,com.google.protobuf.ByteString> handler)

Uses of Handle in de.unistuttgart.isw.sfsc.commonjava.zmq.pubsubsocketpair.inputmanagement.forwarder

Methods in de.unistuttgart.isw.sfsc.commonjava.zmq.pubsubsocketpair.inputmanagement.forwarder that return Handle

Modifier and Type	Method	Description
Handle	Forwarder.addListener(Consumer<List<byte[]>> sink)
Handle	ForwardingInbox.addListener(Consumer<List<byte[]>> listener)

Uses of Handle in de.unistuttgart.isw.sfsc.commonjava.zmq.pubsubsocketpair.inputmanagement.subscription

Methods in de.unistuttgart.isw.sfsc.commonjava.zmq.pubsubsocketpair.inputmanagement.subscription that return Handle

Modifier and Type	Method	Description
Handle	SubscriptionTracker.addListener(Consumer<StoreEvent<com.google.protobuf.ByteString>> listener)
Handle	SubscriptionTrackingInbox.addListener(Consumer<StoreEvent<com.google.protobuf.ByteString>> listener)

Uses of Handle in de.unistuttgart.isw.sfsc.commonjava.zmq.pubsubsocketpair.outputmanagement

Methods in de.unistuttgart.isw.sfsc.commonjava.zmq.pubsubsocketpair.outputmanagement that return Handle

Modifier and Type	Method	Description
Handle	SubscriptionManager.subscribe(byte[] topic)
Handle	SubscriptionManager.subscribe(com.google.protobuf.ByteString topic)
Handle	SubscriptionManager.subscribe(String topic)
Handle	SubscriptionManagerImplementation.subscribe(byte[] topic)
Handle	SubscriptionManagerImplementation.subscribe(com.google.protobuf.ByteString topic)
Handle	SubscriptionManagerImplementation.subscribe(String topic)

Uses of Handle in de.unistuttgart.isw.sfsc.commonjava.zmq.reactor

Methods in de.unistuttgart.isw.sfsc.commonjava.zmq.reactor that return Handle

Modifier and Type	Method	Description
Handle	Reactor.addShutdownListener(Runnable runnable)

Uses of Handle in de.unistuttgart.isw.sfsc.commonjava.zmq.util

Methods in de.unistuttgart.isw.sfsc.commonjava.zmq.util that return Handle

Modifier and Type	Method	Description
Handle	SubscriptionAgent.addSubscriber(com.google.protobuf.ByteString topic, BiConsumer<com.google.protobuf.ByteString,com.google.protobuf.ByteString> messageHandler, Executor executor)
Handle	SubscriptionAgent.addSubscriber(com.google.protobuf.ByteString topic, Predicate<com.google.protobuf.ByteString> filter, BiConsumer<com.google.protobuf.ByteString,com.google.protobuf.ByteString> messageHandler, Executor executor)
Handle	SubscriptionAgent.addSubscriber(Set<com.google.protobuf.ByteString> topics, Predicate<com.google.protobuf.ByteString> filter, BiConsumer<com.google.protobuf.ByteString,com.google.protobuf.ByteString> messageHandler, Executor handlerExecutor)