public class MessageQueueAgent extends java.lang.Object implements IMessageQueueService
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 and Description |
---|
MessageQueueAgent() |
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.
|
protected jadex.bridge.IInternalAccess agent
protected java.util.Map<java.lang.String,java.util.List<jadex.commons.future.SubscriptionIntermediateFuture<Event>>> subscribers
public void agentCreated()
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)
publish
in interface IMessageQueueService
topic
- The topic.event
- The event to publish.