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 SummaryAll 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- 
subscribeISubscriptionIntermediateFuture<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.
 
 
- 
 
-