jadex.micro.examples.messagequeue.replicated

Class ReplicatedMessageQueueAgent

java.lang.Object

jadex.micro.examples.messagequeue.replicated.ReplicatedMessageQueueAgent

All Implemented Interfaces:

IMessageQueueService, IMessageQueueReplicableService, IMessageQueueReplicationService

public class ReplicatedMessageQueueAgent
extends java.lang.Object
implements IMessageQueueReplicableService, IMessageQueueReplicationService

This agent represents a part of a distributed, replicable message queue. It offers a message queue service that is used by the local clients. Also it offers and uses a remote message queue service where other remote services can subscribe to receive and distribute messages from local clients.

Field Summary

Fields

Modifier and Type	Field and Description
protected jadex.bridge.IInternalAccess	agent The agent.
protected java.lang.String	id The service id
protected java.util.Map<java.lang.String,java.util.List<jadex.commons.future.SubscriptionIntermediateFuture<Event>>>	localsubscribers The map of local subscribers.
protected java.util.Map<java.lang.String,java.util.List<jadex.commons.future.SubscriptionIntermediateFuture<Event>>>	repsubscribers The map of the replication subscribers.
protected java.util.Map<java.lang.String,java.util.List<ReplicationSubscription>>	repsubscriptions The map of ReplicationSubscriptions
protected java.lang.Integer	searchinterval The search interval argument.

Constructor Summary

Constructors

Constructor and Description
ReplicatedMessageQueueAgent()

Method Summary

Modifier and Type	Method and Description
void	agentBody()
void	agentCreated() Called on agent creation.
java.lang.String	getId() Returns the services unique Id.
jadex.commons.future.IFuture<java.lang.Void>	publish(java.lang.String topic, Event event) Publish a new event to the queue.
jadex.commons.future.IFuture<java.lang.Void>	publish(java.lang.String topic, Event event, java.lang.Boolean replicate) Publish a new event to the queue.
jadex.commons.future.ISubscriptionIntermediateFuture<Event>	subscribe(java.lang.String topic) Subscribe to a specific topic.
jadex.commons.future.ISubscriptionIntermediateFuture<Event>	subscribeForReplication(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.

localsubscribers

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

The map of local subscribers.

repsubscribers

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

The map of the replication subscribers.

repsubscriptions

protected java.util.Map<java.lang.String,java.util.List<ReplicationSubscription>> repsubscriptions

The map of ReplicationSubscriptions

id

protected java.lang.String id

The service id

searchinterval

protected java.lang.Integer searchinterval

The search interval argument.

Constructor Detail

ReplicatedMessageQueueAgent

public ReplicatedMessageQueueAgent()

Method Detail

agentCreated

public void agentCreated()

Called on agent creation.

agentBody

public void agentBody()

subscribeForReplication

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

Specified by:

subscribeForReplication in interface IMessageQueueReplicationService

Parameters:

topic - The topic.

Returns:

The events.

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. Every time when someone subscribe for local messages the server also subscribe for the given topic by all the other remote services.

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,
                                                            java.lang.Boolean replicate)

Publish a new event to the queue.

Specified by:

publish in interface IMessageQueueReplicableService

Parameters:

topic - The topic.

event - The event to publish.

replicate - Should the event be replicated among all message queues?

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.

getId

public java.lang.String getId()

Returns the services unique Id.

Specified by:

getId in interface IMessageQueueReplicationService

Returns:

the service Id.