Class ClusteredQueueFactory

java.lang.Object
com.swiftmq.impl.queue.standard.cluster.ClusteredQueueFactory
All Implemented Interfaces:
com.swiftmq.swiftlet.queue.QueueFactory
public class ClusteredQueueFactory extends Object implements com.swiftmq.swiftlet.queue.QueueFactory

  • Constructor Details

    • ClusteredQueueFactory

      public ClusteredQueueFactory(SwiftletContext ctx)

  • Method Details

    • registerUsage

      public boolean registerUsage()
      Specified by:
      registerUsage in interface com.swiftmq.swiftlet.queue.QueueFactory

    • createQueue

      public com.swiftmq.swiftlet.queue.AbstractQueue createQueue(String queueName, com.swiftmq.mgmt.Entity clusteredQueueEntity) throws com.swiftmq.swiftlet.queue.QueueException
      Specified by:
      createQueue in interface com.swiftmq.swiftlet.queue.QueueFactory
      Throws:
      com.swiftmq.swiftlet.queue.QueueException