1 10 11 package org.mule.util.queue; 12 13 import org.mule.util.xa.ResourceManagerSystemException; 14 15 23 public interface QueueManager 24 { 25 26 void start() throws ResourceManagerSystemException; 27 28 void stop() throws ResourceManagerSystemException; 29 30 QueueSession getQueueSession(); 31 32 void close(); 33 34 void setDefaultQueueConfiguration(QueueConfiguration config); 35 36 void setQueueConfiguration(String queueName, QueueConfiguration config); 37 38 41 public QueuePersistenceStrategy getPersistenceStrategy(); 42 43 46 public void setPersistenceStrategy(QueuePersistenceStrategy persistenceStrategy); 47 48 public QueuePersistenceStrategy getMemoryPersistenceStrategy(); 49 50 public void setMemoryPersistenceStrategy(QueuePersistenceStrategy memoryPersistenceStrategy); 51 52 } 53 | Popular Tags |