jadex.micro.examples.messagequeue

Class MessageQueueAgent

java.lang.Object

jadex.micro.examples.messagequeue.MessageQueueAgent

All Implemented Interfaces:

IMessageQueueService

public class MessageQueueAgent
extends java.lang.Object
implements IMessageQueueService

This agent represents the central message queue. It offers a message queue service that is used by the clients.

Field Summary

Fields

Modifier and Type	Field and Description
protected jadex.bridge.IInternalAccess	agent The agent.
protected java.util.Map<java.lang.String,java.util.List<jadex.commons.future.SubscriptionIntermediateFuture<Event>>>	subscribers The map of subscribers.

Constructor Summary

Constructors

Constructor and Description
MessageQueueAgent()

Method Summary

Modifier and Type	Method and Description
void	agentCreated() Called on agent creation.
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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

agent

protected jadex.bridge.IInternalAccess agent

The agent.

subscribers

protected java.util.Map<java.lang.String,java.util.List<jadex.commons.future.SubscriptionIntermediateFuture<Event>>> subscribers

The map of subscribers.

Constructor Detail

MessageQueueAgent

public MessageQueueAgent()

Method Detail

agentCreated

public void agentCreated()

Called on agent creation.

subscribe

public 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.

Specified by:

subscribe in interface IMessageQueueService

Parameters:

topic - The topic.

Returns:

The events.

publish

public jadex.commons.future.IFuture<java.lang.Void> publish(java.lang.String topic,
                                                            Event event)

Publish a new event to the queue.

Specified by:

publish in interface IMessageQueueService

Parameters:

topic - The topic.

event - The event to publish.