org.apache.qpid.disttest.jms

Class QpidQueueCreator

java.lang.Object

org.apache.qpid.disttest.jms.QpidQueueCreator

All Implemented Interfaces:

QueueCreator

public class QpidQueueCreator
extends Object
implements QueueCreator

Qpid 0-8..0-10 specific class for creating/deleting queues using a non-JMS API. Uses reflection to invoke methods to retain compatibility with Qpid versions <= 0.32.

Field Summary

Fields inherited from interface org.apache.qpid.disttest.jms.QueueCreator

QUEUE_CREATOR_DRAIN_POLL_TIMEOUT, QUEUE_CREATOR_DRAIN_QUEUE_BEFORE_DELETE, QUEUE_CREATOR_THREAD_POOL_SIZE

Constructor Summary

Constructors

Constructor and Description
QpidQueueCreator()

Method Summary

Modifier and Type	Method and Description
void	createQueues(javax.jms.Connection connection, javax.jms.Session session, List<QueueConfig> configs)
void	deleteQueues(javax.jms.Connection connection, javax.jms.Session session, List<QueueConfig> configs)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QpidQueueCreator

public QpidQueueCreator()

Method Detail

createQueues

public void createQueues(javax.jms.Connection connection,
                         javax.jms.Session session,
                         List<QueueConfig> configs)

Specified by:

createQueues in interface QueueCreator

deleteQueues

public void deleteQueues(javax.jms.Connection connection,
                         javax.jms.Session session,
                         List<QueueConfig> configs)

Specified by:

deleteQueues in interface QueueCreator