org.jboss.test.jbossmq.stress
Class DurableSubscriberTest

java.lang.Object
  extended byTestCase
      extended byorg.jboss.test.JBossTestCase (src) 
          extended byorg.jboss.test.jbossmq.MQBase (src) 
              extended byorg.jboss.test.jbossmq.stress.DurableSubscriberTest
Direct Known Subclasses:
DurableSubOne (src) , DurableSubTwo (src) , FailedDurableSub (src)

public class DurableSubscriberTest
extends MQBase (src)

Durable subscriber tests.

See Also:
Serialized Form

Nested Class Summary
 
Nested classes inherited from class org.jboss.test.jbossmq.MQBase (src)
MQBase.BaseMessageCreator (src) , MQBase.IntRangeMessageCreator (src) , MQBase.IntRangeMessageFilter (src) , MQBase.JMSWorker (src) , MQBase.MessageCreator (src) , MQBase.MessageFilter (src) , MQBase.QosConfig (src) , MQBase.QueueWorker (src) , MQBase.TopicWorker (src)
 
Field Summary
 
Fields inherited from class org.jboss.test.jbossmq.MQBase (src)
CONNECTOR, context, DEFAULT_RUNSLEEP, FAILSAFE_SUBSCRIBER, GETTER, log, PUBLISHER, QUEUE_FACTORY, queueFactory, SUBSCRIBER, TEST_QUEUE, TEST_TOPIC, TOPIC_FACTORY, topicFactory, TRANS_DESC, TRANS_INDIVIDUAL, TRANS_NONE, TRANS_TOTAL
 
Fields inherited from class org.jboss.test.JBossTestCase (src)
delegate, deploymentException
 
Constructor Summary
DurableSubscriberTest(java.lang.String name)
           
 
Method Summary
static void main(java.lang.String[] args)
           
 void runBadClient()
          Test connecting as a durable subscriber and diconecction without taking the connection down properly
 void runDurableSubscriberPartOne()
          Test setting up a durable subscription.
 void runDurableSubscriberPartTwo()
          Part two of durable subscriber test, part one should be run before this is run.
 void runGoodClient()
           
static junit.framework.Test suite()
           
 void testDurableSubscriber()
           
 
Methods inherited from class org.jboss.test.jbossmq.MQBase (src)
drainQueue, drainTopic, getRunSleep, setUp, 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
 

Constructor Detail

DurableSubscriberTest

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

runDurableSubscriberPartOne

public void runDurableSubscriberPartOne()
                                 throws java.lang.Exception
Test setting up a durable subscription. Disconnect after half the messages have been sent. Connect later to see if they are still there. This test is done it two parts to be able to take down the server in between

Throws:
java.lang.Exception

runDurableSubscriberPartTwo

public void runDurableSubscriberPartTwo()
                                 throws java.lang.Exception
Part two of durable subscriber test, part one should be run before this is run.

Throws:
java.lang.Exception

testDurableSubscriber

public void testDurableSubscriber()
                           throws java.lang.Exception
Throws:
java.lang.Exception

runGoodClient

public void runGoodClient()
                   throws java.lang.Exception
Throws:
java.lang.Exception

runBadClient

public void runBadClient()
                  throws java.lang.Exception
Test connecting as a durable subscriber and diconecction without taking the connection down properly

Throws:
java.lang.Exception

suite

public static junit.framework.Test suite()
                                  throws java.lang.Exception
Throws:
java.lang.Exception

main

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