public interface IMessageQueueReplicableService extends IMessageQueueService
IMessageQueueService
.Modifier and Type | Method and Description |
---|---|
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.
|
publish, subscribe
jadex.commons.future.IFuture<java.lang.Void> publish(java.lang.String topic, Event event, java.lang.Boolean replicate)
topic
- The topic.event
- The event to publish.replicate
- Should the event be replicated among all message queues?