Interface IMessageQueueService
-
- All Known Subinterfaces:
IMessageQueueReplicableService
- All Known Implementing Classes:
MessageQueueAgent
,ReplicatedMessageQueueAgent
public interface IMessageQueueService
Message 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.
-
-