Interface IMessageQueueService

    • 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.
      • publish

        IFuture<java.lang.Void> publish​(java.lang.String topic,
                                        Event event)
        Publish a new event to the queue.
        Parameters:
        topic - The topic.
        event - The event to publish.