Interface IMessageQueueService

All Known Implementing Classes:
MessageQueueAgent

public interface IMessageQueueService
Message queue interface. Allows for subscribing to topics and publishing events to the queue.
  • Method Summary

    Modifier and Type
    Method
    Description
    jadex.future.IFuture<Void>
    publish(String topic, Event event)
    Publish a new event to the queue.
    jadex.future.ISubscriptionIntermediateFuture<Event>
    Subscribe to a specific topic.
  • Method Details

    • subscribe

      jadex.future.ISubscriptionIntermediateFuture<Event> subscribe(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

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