Package jadex.micro.examples.messagequeue.replicated

Interface IMessageQueueReplicationService

  • All Known Implementing Classes:
    ReplicatedMessageQueueAgent
    public interface IMessageQueueReplicationService
    Message queue interface for the replication of distributed message queues.

    • Method Detail

      • subscribeForReplication

        ISubscriptionIntermediateFuture<Event> subscribeForReplication​(java.lang.String topic)
        Subscribe to a specific topic. New events that fit to the topic are forwarded to all replication subscribers as intermediate results. A subscribe can unsubscribe by terminating the future.
        Parameters:
        topic - The topic.
        Returns:
        The events.

      • getIdString

        java.lang.String getIdString()
        Returns the services unique Id.
        Returns:
        the service Id.