Interface IMessageQueueService
-
- All Known Subinterfaces:
IMessageQueueReplicableService
- All Known Implementing Classes:
MessageQueueAgent,ReplicatedMessageQueueAgent
public interface IMessageQueueServiceMessage queue interface. Allows for subscribing to topics and publishing events to the queue.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description IFuture<java.lang.Void>publish(java.lang.String topic, Event event)Publish a new event to the queue.ISubscriptionIntermediateFuture<Event>subscribe(java.lang.String topic)Subscribe to a specific topic.
-
-
-
Method Detail
-
subscribe
ISubscriptionIntermediateFuture<Event> subscribe(java.lang.String topic)
Subscribe to a specific topic. New events that fit to the topic are forwarded to all subscribers as intermediate results. A subscribe can unsubscribe by terminating the future.- Parameters:
topic- The topic.- Returns:
- The events.
-
-