public class ReplicatedMessageQueueAgent extends java.lang.Object implements IMessageQueueReplicableService, IMessageQueueReplicationService
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
ReplicationSubscription s |
protected java.lang.Integer |
searchinterval
The search interval argument.
|
Constructor and Description |
---|
ReplicatedMessageQueueAgent() |
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.
|
protected jadex.bridge.IInternalAccess agent
protected java.util.Map<java.lang.String,java.util.List<jadex.commons.future.SubscriptionIntermediateFuture<Event>>> localsubscribers
protected java.util.Map<java.lang.String,java.util.List<jadex.commons.future.SubscriptionIntermediateFuture<Event>>> repsubscribers
protected java.util.Map<java.lang.String,java.util.List<ReplicationSubscription>> repsubscriptions
ReplicationSubscription
sprotected java.lang.String id
protected java.lang.Integer searchinterval
public void agentCreated()
public void agentBody()
public jadex.commons.future.ISubscriptionIntermediateFuture<Event> subscribeForReplication(java.lang.String topic)
subscribeForReplication
in interface IMessageQueueReplicationService
topic
- The topic.public jadex.commons.future.ISubscriptionIntermediateFuture<Event> subscribe(java.lang.String topic)
subscribe
in interface IMessageQueueService
topic
- The topic.public jadex.commons.future.IFuture<java.lang.Void> publish(java.lang.String topic, Event event, java.lang.Boolean replicate)
publish
in interface IMessageQueueReplicableService
topic
- The topic.event
- The event to publish.replicate
- Should the event be replicated among all message queues?public jadex.commons.future.IFuture<java.lang.Void> publish(java.lang.String topic, Event event)
publish
in interface IMessageQueueService
topic
- The topic.event
- The event to publish.public java.lang.String getId()
getId
in interface IMessageQueueReplicationService