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 Summary

Modifier and Type	Method and Description
java.lang.String	getId() Returns the services unique Id.
jadex.commons.future.ISubscriptionIntermediateFuture<Event>	subscribeForReplication(java.lang.String topic) Subscribe to a specific topic.

Method Detail

subscribeForReplication

jadex.commons.future.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.

getId

java.lang.String getId()

Returns the services unique Id.

Returns:

the service Id.