Class SubscriptionAgent
- java.lang.Object
-
- de.unistuttgart.isw.sfsc.commonjava.zmq.util.SubscriptionAgent
-
public class SubscriptionAgent extends Object
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description HandleaddSubscriber(com.google.protobuf.ByteString topic, BiConsumer<com.google.protobuf.ByteString,com.google.protobuf.ByteString> messageHandler, Executor executor)HandleaddSubscriber(com.google.protobuf.ByteString topic, Predicate<com.google.protobuf.ByteString> filter, BiConsumer<com.google.protobuf.ByteString,com.google.protobuf.ByteString> messageHandler, Executor executor)HandleaddSubscriber(Set<com.google.protobuf.ByteString> topics, Predicate<com.google.protobuf.ByteString> filter, BiConsumer<com.google.protobuf.ByteString,com.google.protobuf.ByteString> messageHandler, Executor handlerExecutor)static SubscriptionAgentcreate(PubSubConnection pubSubConnection)
-
-
-
Method Detail
-
create
public static SubscriptionAgent create(PubSubConnection pubSubConnection)
-
addSubscriber
public Handle 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)
-
addSubscriber
public Handle addSubscriber(com.google.protobuf.ByteString topic, Predicate<com.google.protobuf.ByteString> filter, BiConsumer<com.google.protobuf.ByteString,com.google.protobuf.ByteString> messageHandler, Executor executor)
-
addSubscriber
public Handle addSubscriber(com.google.protobuf.ByteString topic, BiConsumer<com.google.protobuf.ByteString,com.google.protobuf.ByteString> messageHandler, Executor executor)
-
-