jadex.micro.examples.messagequeue

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

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

Method Detail

subscribe

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

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