org.jboss.test.jbossmq
Class MQBase

java.lang.Object
  extended byTestCase
      extended byorg.jboss.test.JBossTestCase (src) 
          extended byorg.jboss.test.jbossmq.MQBase
Direct Known Subclasses:
DurableSubscriberTest (src) , ExceptionListenerTest (src) , MassiveTest (src) , MultipleDurableSubscribers (src) , QueueTest (src) , SecurityUnitTestCase (src)

public class MQBase
extends JBossTestCase (src)

JMS tests base class. Your test extends this class, and can then use common methods. To do the tests you use TopicWorker or QueueWorker and the MessageCreator, MessageFilter and perhaps MessageQos classes, directly or by extending them. You can change the connection factories and destinations used by the properties: jbosstest.queuefactory, jbosstest.topicfactory, jbosstest.queue or jbosstest.topic.

See Also:
Serialized Form

Nested Class Summary
 class MQBase.BaseMessageCreator (src)
           
 class MQBase.IntRangeMessageCreator (src)
           
 class MQBase.IntRangeMessageFilter (src)
           
 class MQBase.JMSWorker (src)
           
static interface MQBase.MessageCreator (src)
           
static interface MQBase.MessageFilter (src)
           
 class MQBase.QosConfig (src)
          Defines quality of service for message publishing.
 class MQBase.QueueWorker (src)
           
 class MQBase.TopicWorker (src)
           
 
Field Summary
static int CONNECTOR
           
 javax.naming.Context context
           
static int DEFAULT_RUNSLEEP
           
static int FAILSAFE_SUBSCRIBER
           
static int GETTER
           
 Category log
           
static int PUBLISHER
           
 java.lang.String QUEUE_FACTORY
           
 QueueConnectionFactory (src) queueFactory
           
static int SUBSCRIBER
           
 java.lang.String TEST_QUEUE
           
 java.lang.String TEST_TOPIC
           
 java.lang.String TOPIC_FACTORY
           
 TopicConnectionFactory (src) topicFactory
           
static java.lang.String[] TRANS_DESC
           
static int TRANS_INDIVIDUAL
           
static int TRANS_NONE
           
static int TRANS_TOTAL
           
 
Fields inherited from class org.jboss.test.JBossTestCase (src)
delegate, deploymentException
 
Constructor Summary
MQBase(java.lang.String name)
           
 
Method Summary
 void drainQueue()
           
 void drainTopic()
           
 long getRunSleep()
           
static void main(java.lang.String[] args)
           
protected  void setUp()
          The JUnit setup method
 void sleep(long sleep)
           
 
Methods inherited from class org.jboss.test.JBossTestCase (src)
deploy, flushAuthCache, flushAuthCache, getBeanCount, getDeployerName, getDeploySetup, getDeployURL, getInitialContext, getIterationCount, getJndiInitFactory, getJndiURL, getLog, getResourceURL, getServer, getServerHost, getThreadCount, initDelegate, invoke, restartDBPool, testServerFound, undeploy
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

PUBLISHER

public static final int PUBLISHER
See Also:
Constant Field Values (src)

SUBSCRIBER

public static final int SUBSCRIBER
See Also:
Constant Field Values (src)

GETTER

public static final int GETTER
See Also:
Constant Field Values (src)

CONNECTOR

public static final int CONNECTOR
See Also:
Constant Field Values (src)

FAILSAFE_SUBSCRIBER

public static final int FAILSAFE_SUBSCRIBER
See Also:
Constant Field Values (src)

TRANS_NONE

public static final int TRANS_NONE
See Also:
Constant Field Values (src)

TRANS_INDIVIDUAL

public static final int TRANS_INDIVIDUAL
See Also:
Constant Field Values (src)

TRANS_TOTAL

public static final int TRANS_TOTAL
See Also:
Constant Field Values (src)

TRANS_DESC

public static final java.lang.String[] TRANS_DESC

DEFAULT_RUNSLEEP

public static final int DEFAULT_RUNSLEEP
See Also:
Constant Field Values (src)

log

public final Category log

TOPIC_FACTORY

public java.lang.String TOPIC_FACTORY

QUEUE_FACTORY

public java.lang.String QUEUE_FACTORY

TEST_QUEUE

public java.lang.String TEST_QUEUE

TEST_TOPIC

public java.lang.String TEST_TOPIC

context

public javax.naming.Context context

queueFactory

public QueueConnectionFactory (src)  queueFactory

topicFactory

public TopicConnectionFactory (src)  topicFactory
Constructor Detail

MQBase

public MQBase(java.lang.String name)
Method Detail

getRunSleep

public long getRunSleep()

sleep

public void sleep(long sleep)
Overrides:
sleep in class JBossTestCase (src)

drainTopic

public void drainTopic()
                throws JMSException (src) 
Throws:
JMSException (src)

drainQueue

public void drainQueue()
                throws JMSException (src) 
Throws:
JMSException (src)

setUp

protected void setUp()
              throws java.lang.Exception
The JUnit setup method

Throws:
java.lang.Exception - Description of Exception

main

public static void main(java.lang.String[] args)