Please rename it one way or the other. If it repeats something, call it a
stress test, these are run separately from unit tests.
IMNSHO a misnamed test that is not run automatically is almost worse than
no test at all, because the test writer is apt to think the feature is
getting tested when it is not.
No matter how long it takes to run, I think being able to run _all_ the
tests automatically is _essential_
david jencks
On 2002.03.06 15:37:59 -0500 [EMAIL PROTECTED] wrote:
> On 6 Mar, David Jencks wrote:
> > Maybe you aren't done here... but the naming convention to get your
> tests
> > run in the testsuite without any other code is to name them
> >
>
> Yea thanks, but all the other tests in JBossMQ appart from the JBoss...
> is not names UnitTestCase either, and since jason even wanted to remove
> the that one from the normal run I tought it would do to have it when
> you run -Dtest=jbossmq test
>
> Maybe I will change it later.
>
> //Peter
> > xxxUnitTestCase
> > or
> > xxxStressTestCase
> >
> > david jencks
> >
> > On 2002.03.06 12:33:31 -0500 Peter Antman wrote:
> >> User: pra
> >> Date: 02/03/06 09:33:31
> >>
> >> Added: src/main/org/jboss/test/jbossmq/test
> SecurityTestCase.java
> >> Log:
> >> Added testcases to test the new security architecture
> >>
> >> Revision Changes Path
> >> 1.1
>jbosstest/src/main/org/jboss/test/jbossmq/test/SecurityTestCase.java
> >>
> >> Index: SecurityTestCase.java
> >> ===================================================================
> >> /*
> >> * JBoss, the OpenSource EJB server
> >> *
> >> * Distributable under LGPL license.
> >> * See terms of license at gnu.org.
> >> */
> >> package org.jboss.test.jbossmq.test;
> >>
> >> import junit.framework.TestSuite;
> >> import junit.framework.Assert;
> >>
> >> import org.jboss.test.jbossmq.MQBase;
> >> /**
> >> * Test of security features in JBossMQ
> >> *
> >> *
> >> * @author <a href="[EMAIL PROTECTED]">Peter Antman</a>
> >> * @version $Revision: 1.1 $
> >> */
> >>
> >> public class SecurityTestCase extends MQBase{
> >>
> >> public SecurityTestCase(String name) {
> >> super(name);
> >> }
> >>
> >> public void runLoginTest() throws Exception{
> >> TopicWorker sub1 = null;
> >> TopicWorker pub1 = null;
> >> try {
> >> drainTopic();
> >> int ic = getIterationCount();
> >>
> >> IntRangeMessageFilter f1 = new
> >> IntRangeMessageFilter(javax.jms.Message.class,
> >>
> >> "USER_NR",
> >> 0,
> >> ic);
> >>
> >> sub1 = new TopicWorker(SUBSCRIBER,
> >> TRANS_NONE,
> >> f1);
> >> sub1.setUser("john", "needle");
> >> Thread t1 = new Thread(sub1);
> >> t1.start();
> >>
> >> // Publish
> >> IntRangeMessageCreator c1 = new
> >> IntRangeMessageCreator("USER_NR",
> >> 0);
> >> pub1 = new TopicWorker(PUBLISHER,
> >> TRANS_NONE,
> >> c1,
> >> ic);
> >> pub1.connect();
> >> pub1.publish();
> >>
> >> Assert.assertEquals("Publisher did not publish correct
> number
> >> of messages "+pub1.getMessageHandled(),
> >> ic,
> >> pub1.getMessageHandled());
> >>
> >> // let sub1 have some time to handle the messages.
> >> log.debug("Sleeping for " + ((ic*10)/60000) + " minutes");
> >> sleep(ic*10);
> >>
> >>
> >> Assert.assertEquals("Subscriber did not get correct number
> of
> >> messages "+sub1.getMessageHandled(),
> >> ic,
> >> sub1.getMessageHandled());
> >> sub1.close();
> >> pub1.close();
> >> }catch(Throwable t) {
> >> if (t instanceof junit.framework.AssertionFailedError)
> >> throw (junit.framework.AssertionFailedError)t;
> >>
> >> log.error("Error in test: " +t,t);
> >> throw new Exception(t.getMessage());
> >> }finally {
> >> try {
> >> if (sub1 != null)
> >> sub1.close();
> >> }catch(Exception ex) {}
> >> try {
> >> if (pub1 != null)
> >> pub1.close();
> >> }catch(Exception ex) {}
> >> }
> >>
> >> }
> >>
> >> /**
> >> Tests that check authentication
> >> 1. Login without cred
> >> 2. Login with valid usedid,pwd
> >> 3. Login with valid user, unvalid pwd
> >> 4. Login with unvalid user.
> >> */
> >> public void runLoginNoCred()throws Exception {
> >> TopicWorker pub1 = null;
> >> try {
> >> drainTopic();
> >> pub1 = new TopicWorker(PUBLISHER,
> >> TRANS_NONE,
> >> null,
> >> 0);
> >> pub1.connect();
> >> }catch(Exception ex) {
> >> Assert.fail("Could lot login without any cred");
> >> } finally {
> >> try {
> >> pub1.close();
> >> }catch(Exception ex) {
> >>
> >> }
> >> }
> >> }
> >>
> >> public void runLoginValidCred() throws Exception{
> >> TopicWorker pub1 = null;
> >> try {
> >> drainTopic();
> >> pub1 = new TopicWorker(PUBLISHER,
> >> TRANS_NONE,
> >> null,
> >> 0);
> >> pub1.setUser("john", "needle");
> >> pub1.connect();
> >> }catch(Exception ex) {
> >> Assert.fail("Could lot login with valid cred");
> >> } finally {
> >> try {
> >> pub1.close();
> >> }catch(Exception ex) {
> >>
> >> }
> >> }
> >> }
> >>
> >> public void runLoginInvalidPwd() throws Exception{
> >> TopicWorker pub1 = null;
> >> try {
> >> drainTopic();
> >> pub1 = new TopicWorker(PUBLISHER,
> >> TRANS_NONE,
> >> null,
> >> 0);
> >> pub1.setUser("john", "bogus");
> >> Exception e = null;
> >> try {
> >> pub1.connect();
> >> }catch(Exception ex) {
> >> e = ex;
> >> }
> >> log.debug(e);
> >> Assert.assertTrue("Loggin in with invalid password did not
> >> throw correct exception", e instanceof
> javax.jms.JMSSecurityException);
> >>
> >> } finally {
> >> try {
> >> pub1.close();
> >> }catch(Exception ex) {
> >>
> >> }
> >> }
> >> }
> >> public void runLoginInvalidCred() throws Exception{
> >> TopicWorker pub1 = null;
> >> try {
> >> drainTopic();
> >> pub1 = new TopicWorker(PUBLISHER,
> >> TRANS_NONE,
> >> null,
> >> 0);
> >> pub1.setUser("bogus", "bogus");
> >> Exception e = null;
> >> try {
> >> pub1.connect();
> >> }catch(Exception ex) {
> >> e = ex;
> >> }
> >> log.debug(e);
> >> Assert.assertTrue("Loggin in with invalid user did not
> throw
> >> correct exception", e instanceof javax.jms.JMSSecurityException);
> >>
> >> } finally {
> >> try {
> >> pub1.close();
> >> }catch(Exception ex) {
> >>
> >> }
> >> }
> >> }
> >>
> >>
> >>
> >> /**
> >> An number of tests to verrify that clientID works as expected:
> >>
> >> 1. Nothing. getClientID should return a string starting withID
> >> 2. user/pwd with preconfigured clientID, should return preconf
> >> 3. setClientID, should return the set clientID
> >> 4. setClienID starting with ID, should trow invalid clientID
> >> 5. setClientID same as a preconf, should trow invalid clientID
> >> 6. setClientID after any method beeing invoked on con, throw
> >> invalid state
> >> */
> >> public void runClientIDNormalTest() throws Exception {
> >> TopicWorker pub1 = null;
> >> try {
> >> drainTopic();
> >> int ic = getIterationCount();
> >>
> >> // Publish
> >> IntRangeMessageCreator c1 = new
> >> IntRangeMessageCreator("USER_NR",
> >> 0);
> >> pub1 = new TopicWorker(PUBLISHER,
> >> TRANS_NONE,
> >> c1,
> >> ic);
> >> pub1.connect();
> >> pub1.publish();
> >>
> >> Assert.assertTrue("Client did not get a valid clientID",
> >> pub1.connection.getClientID().startsWith("ID"));
> >> pub1.close();
> >>
> >> }catch(Throwable t) {
> >> if (t instanceof junit.framework.AssertionFailedError)
> >> throw (junit.framework.AssertionFailedError)t;
> >> log.error("Error in test: " +t,t);
> >> throw new Exception(t.getMessage());
> >> }finally {
> >> try {
> >> pub1.close();
> >> }catch(Exception ex) {
> >>
> >> }
> >> }
> >> }
> >> public void runClientIDPreconfTest() throws Exception {
> >> TopicWorker pub1 = null;
> >> try {
> >> drainTopic();
> >> int ic = getIterationCount();
> >>
> >> // Publish
> >> IntRangeMessageCreator c1 = new
> >> IntRangeMessageCreator("USER_NR",
> >> 0);
> >> pub1 = new TopicWorker(PUBLISHER,
> >> TRANS_NONE,
> >> c1,
> >> ic);
> >> pub1.setUser("john","needle");
> >> pub1.connect();
> >> pub1.publish();
> >>
> >> Assert.assertEquals("Client did not get a valid clientID",
> >> "DurableSubscriberExample",pub1.connection.getClientID());
> >> pub1.close();
> >>
> >> }catch(Throwable t) {
> >> if (t instanceof junit.framework.AssertionFailedError)
> >> throw (junit.framework.AssertionFailedError)t;
> >> log.error("Error in test: " +t,t);
> >> throw new Exception(t.getMessage());
> >> }finally {
> >> try {
> >> pub1.close();
> >> }catch(Exception ex) {
> >>
> >> }
> >> }
> >> }
> >>
> >> public void runClientIDSetTest() throws Exception {
> >> TopicWorker pub1 = null;
> >> try {
> >> drainTopic();
> >> int ic = getIterationCount();
> >>
> >> // Publish
> >> IntRangeMessageCreator c1 = new
> >> IntRangeMessageCreator("USER_NR",
> >> 0);
> >> pub1 = new TopicWorker(PUBLISHER,
> >> TRANS_NONE,
> >> c1,
> >> ic);
> >> pub1.setClientID("myId");
> >> pub1.connect();
> >> pub1.publish();
> >>
> >> Assert.assertEquals("Client did not get a valid clientID",
> >> "myId",pub1.connection.getClientID());
> >> pub1.close();
> >>
> >> }catch(Throwable t) {
> >> if (t instanceof junit.framework.AssertionFailedError)
> >> throw (junit.framework.AssertionFailedError)t;
> >> log.error("Error in test: " +t,t);
> >> throw new Exception(t.getMessage());
> >> }finally {
> >> try {
> >> pub1.close();
> >> }catch(Exception ex) {
> >>
> >> }
> >> }
> >> }
> >> public void runClientIDSetInternal() throws Exception {
> >> TopicWorker pub1 = null;
> >> try {
> >> drainTopic();
> >> int ic = getIterationCount();
> >>
> >> // Publish
> >> IntRangeMessageCreator c1 = new
> >> IntRangeMessageCreator("USER_NR",
> >> 0);
> >> pub1 = new TopicWorker(PUBLISHER,
> >> TRANS_NONE,
> >> c1,
> >> ic);
> >> pub1.setClientID("ID123");
> >> Exception e = null;
> >> try {
> >> pub1.connect();
> >> }catch(Exception ex) {
> >> e = ex;
> >> }
> >> log.debug(e);
> >> Assert.assertTrue("Setting a clientID looking like an
> internal
> >> did not throw correct exception", e instanceof
> >> javax.jms.InvalidClientIDException);
> >>
> >> pub1.close();
> >>
> >> }catch(Throwable t) {
> >> if (t instanceof junit.framework.AssertionFailedError)
> >> throw (junit.framework.AssertionFailedError)t;
> >> log.error("Error in test: " +t,t);
> >> throw new Exception(t.getMessage());
> >> }finally {
> >> try {
> >> pub1.close();
> >> }catch(Exception ex) {
> >>
> >> }
> >> }
> >> }
> >>
> >> public void runClientIDSetSteelPreconf() throws Exception {
> >> TopicWorker pub1 = null;
> >> try {
> >> drainTopic();
> >> int ic = getIterationCount();
> >>
> >> // Publish
> >> IntRangeMessageCreator c1 = new
> >> IntRangeMessageCreator("USER_NR",
> >> 0);
> >> pub1 = new TopicWorker(PUBLISHER,
> >> TRANS_NONE,
> >> c1,
> >> ic);
> >> pub1.setClientID("DurableSubscriberExample");
> >> Exception e = null;
> >> try {
> >> pub1.connect();
> >> }catch(Exception ex) {
> >> e = ex;
> >> }
> >> log.debug(e);
> >> Assert.assertTrue("Setting a clientID wich is preconfigured
> >> did not throw correct exception", e instanceof
> >> javax.jms.InvalidClientIDException);
> >>
> >> pub1.close();
> >>
> >> }catch(Throwable t) {
> >> if (t instanceof junit.framework.AssertionFailedError)
> >> throw (junit.framework.AssertionFailedError)t;
> >> log.error("Error in test: " +t,t);
> >> throw new Exception(t.getMessage());
> >> }finally {
> >> try {
> >> pub1.close();
> >> }catch(Exception ex) {
> >>
> >> }
> >> }
> >> }
> >> public void runClientIDSetAfterInvoke() throws Exception {
> >> TopicWorker pub1 = null;
> >> try {
> >> drainTopic();
> >> int ic = getIterationCount();
> >>
> >> // Publish
> >> IntRangeMessageCreator c1 = new
> >> IntRangeMessageCreator("USER_NR",
> >> 0);
> >> pub1 = new TopicWorker(PUBLISHER,
> >> TRANS_NONE,
> >> c1,
> >> ic);
> >>
> >> pub1.connect();
> >> pub1.publish();
> >> Exception e = null;
> >> try {
> >> pub1.connection.setClientID("myID");
> >>
> >> }catch(Exception ex) {
> >> e = ex;
> >> }
> >> log.debug(e);
> >> Assert.assertTrue("Setting a clientID after connection is
> used
> >> did not throw correct exception: " +e, e instanceof
> >> IllegalStateException);
> >>
> >> pub1.close();
> >>
> >> }catch(Throwable t) {
> >> if (t instanceof junit.framework.AssertionFailedError)
> >> throw (junit.framework.AssertionFailedError)t;
> >> log.error("Error in test: " +t,t);
> >> throw new Exception(t.getMessage());
> >> }finally {
> >> try {
> >> pub1.close();
> >> }catch(Exception ex) {
> >>
> >> }
> >> }
> >> }
> >>
> >>
> >> /**
> >> Tests to check autorization.
> >>
> >> Remember there are actuallt two types of fails:
> >> a) You are a user, but do no belong to a group that has acl.
> >> b) You belong to a group, but that group does not have acl.
> >> we test the first for topics and the second for queues, by
> >> configuration in jbossmq-testsuite-service.xml
> >>
> >> Tests that check autorization.
> >> 1. test valid topic publisher
> >> 2. test invalid topic publisher
> >> 3. test valid topic subscriber
> >> 4. test invalid topic subscriber
> >> 5. test valid queue sender
> >> 6. test invalid queue sender
> >> 7. test valid queue receiver
> >> 8. test invalid queue receiver
> >> 9. test valid queue browser.
> >> 10. test invalid queue browser
> >> 11. test preconf dur sub, to valid dest.
> >> 12. test preconf dur sub, to invalid dest.
> >> 13. test dyn dur sub, to valid dest.
> >> 14. test dyn dur sub, to valid dest.
> >> */
> >> public void runAuzValidTopicPublisher() throws Exception {
> >> TopicWorker pub1 = null;
> >> try {
> >> IntRangeMessageCreator c1 = new
> >> IntRangeMessageCreator("USER_NR",
> >> 0);
> >> pub1 = new TopicWorker(PUBLISHER,
> >> TRANS_NONE,
> >> c1,
> >> 1);
> >> pub1.setUser("john", "needle");
> >> pub1.connect();
> >> pub1.publish();
> >> }catch(Exception ex) {
> >> Assert.fail("Could not publish to valid destination");
> >> }finally {
> >> try {
> >> pub1.close();
> >> }catch(Exception ex) {
> >>
> >> }
> >> }
> >> }
> >>
> >> public void runAuzInvalidTopicPublisher() throws Exception {
> >> TopicWorker pub1 = null;
> >> try {
> >> IntRangeMessageCreator c1 = new
> >> IntRangeMessageCreator("USER_NR",
> >> 0);
> >> pub1 = new TopicWorker(PUBLISHER,
> >> TRANS_NONE,
> >> c1,
> >> 1);
> >> pub1.setUser("nobody", "nobody");
> >> pub1.connect();
> >>
> >> Exception e = null;
> >> try {
> >> pub1.publish();
> >> }catch(Exception ex) {
> >> e = ex;
> >> }
> >> log.debug(e);
> >> Assert.assertTrue("Unauz topic publishing throw wrong
> >> exception: "+e, e instanceof javax.jms.JMSSecurityException);
> >>
> >> }finally {
> >> try {
> >> pub1.close();
> >> }catch(Exception ex) {
> >>
> >> }
> >> }
> >> }
> >>
> >> public void runAuzValidTopicSubscriber() throws Exception {
> >> TopicWorker sub1 = null;
> >> try {
> >> drainTopic();
> >> IntRangeMessageFilter f1 = new
> >> IntRangeMessageFilter(javax.jms.Message.class,
> >>
> >> "USER_NR",
> >> 0,
> >> 1);
> >> sub1 = new TopicWorker(SUBSCRIBER,
> >> TRANS_NONE,
> >> f1);
> >>
> >> sub1.setUser("john", "needle");
> >> Thread t1 = new Thread(sub1);
> >> t1.start();
> >> sleep(1000L);
> >>
> >> Exception ex = sub1.getException();
> >>
> >> t1.stop();
> >> Assert.assertTrue("Autz topic subscriber did not work", ex
> ==
> >> null);
> >>
> >>
> >> }finally {
> >> try {
> >> sub1.close();
> >> }catch(Exception ex) {
> >>
> >> }
> >> }
> >> }
> >>
> >> public void runAuzInvalidTopicSubscriber() throws Exception {
> >> TopicWorker sub1 = null;
> >> try {
> >> drainTopic();
> >> IntRangeMessageFilter f1 = new
> >> IntRangeMessageFilter(javax.jms.Message.class,
> >>
> >> "USER_NR",
> >> 0,
> >> 1);
> >> sub1 = new TopicWorker(SUBSCRIBER,
> >> TRANS_NONE,
> >> f1);
> >>
> >> sub1.setUser("nobody", "nobody");
> >> Thread t1 = new Thread(sub1);
> >> t1.start();
> >> sleep(1000L);
> >>
> >> Exception ex = sub1.getException();
> >>
> >> t1.stop();
> >> Assert.assertTrue("Unautz topic subscriber throw wrong
> >> exception: " +ex, ex instanceof javax.jms.JMSSecurityException);
> >>
> >>
> >> }finally {
> >> try {
> >> sub1.close();
> >> }catch(Exception ex) {
> >>
> >> }
> >> }
> >> }
> >>
> >> public void runAuzValidQueueSender() throws Exception {
> >> QueueWorker pub1 = null;
> >> try {
> >> IntRangeMessageCreator c1 = new
> >> IntRangeMessageCreator("USER_NR",
> >> 0);
> >> pub1 = new QueueWorker(PUBLISHER,
> >> TRANS_NONE,
> >> c1,
> >> 1);
> >> pub1.setUser("john", "needle");
> >> pub1.connect();
> >> pub1.publish();
> >> }catch(Exception ex) {
> >> Assert.fail("Could not publish to valid destination");
> >> }finally {
> >> try {
> >> pub1.close();
> >> }catch(Exception ex) {
> >>
> >> }
> >> }
> >> }
> >>
> >> public void runAuzInvalidQueueSender() throws Exception {
> >> QueueWorker pub1 = null;
> >> try {
> >> IntRangeMessageCreator c1 = new
> >> IntRangeMessageCreator("USER_NR",
> >> 0);
> >> pub1 = new QueueWorker(PUBLISHER,
> >> TRANS_NONE,
> >> c1,
> >> 1);
> >> pub1.setUser("nobody", "nobody");
> >> pub1.connect();
> >>
> >> Exception e = null;
> >> try {
> >> pub1.publish();
> >> }catch(Exception ex) {
> >> e = ex;
> >> }
> >> log.debug(e);
> >> Assert.assertTrue("Unauz queue publishing throw wrong
> >> exception: "+e, e instanceof javax.jms.JMSSecurityException);
> >>
> >> }finally {
> >> try {
> >> pub1.close();
> >> }catch(Exception ex) {
> >>
> >> }
> >> }
> >> }
> >>
> >> public void runAuzValidQueueReceiver() throws Exception {
> >> QueueWorker sub1 = null;
> >> try {
> >>
> >> IntRangeMessageFilter f1 = new
> >> IntRangeMessageFilter(javax.jms.Message.class,
> >>
> >> "USER_NR",
> >> 0,
> >> 1);
> >> sub1 = new QueueWorker(GETTER,
> >> TRANS_NONE,
> >> f1);
> >>
> >> sub1.setUser("john", "needle");
> >> sub1.connect();
> >> Exception ex = null;
> >> try {
> >> sub1.get();
> >> }catch(Exception e){
> >> ex =e;
> >> log.error("ValidQueueReceiver got an exception: " +
> e,e);
> >> }
> >> Assert.assertTrue("Autz queue receiver did not work", ex ==
> >> null);
> >>
> >>
> >> }finally {
> >> try {
> >> sub1.close();
> >> }catch(Exception ex) {
> >>
> >> }
> >> }
> >> }
> >>
> >> public void runAuzInvalidQueueReceiver() throws Exception {
> >> QueueWorker sub1 = null;
> >> try {
> >>
> >> IntRangeMessageFilter f1 = new
> >> IntRangeMessageFilter(javax.jms.Message.class,
> >>
> >> "USER_NR",
> >> 0,
> >> 1);
> >> sub1 = new QueueWorker(GETTER,
> >> TRANS_NONE,
> >> f1);
> >>
> >> sub1.setUser("nobody", "nobody");
> >> sub1.connect();
> >> Exception ex = null;
> >> try {
> >> sub1.get();
> >> }catch(Exception e){
> >> ex =e;
> >> }
> >> Assert.assertTrue("Unautz queue receiver throw wrong
> >> exception: " +ex, ex instanceof javax.jms.JMSSecurityException);
> >>
> >>
> >> }finally {
> >> try {
> >> sub1.close();
> >> }catch(Exception ex) {
> >>
> >> }
> >> }
> >> }
> >>
> >> public void runAuzValidQueueBrowser() throws Exception {
> >> QueueWorker sub1 = null;
> >> try {
> >>
> >> IntRangeMessageFilter f1 = new
> >> IntRangeMessageFilter(javax.jms.Message.class,
> >>
> >> "USER_NR",
> >> 0,
> >> 1);
> >> sub1 = new QueueWorker(GETTER,
> >> TRANS_NONE,
> >> f1);
> >>
> >> sub1.setUser("john", "needle");
> >> sub1.connect();
> >> Exception ex = null;
> >> try {
> >> sub1.browse();
> >> }catch(Exception e){
> >> ex =e;
> >> log.error("ValidQueueBrowser throw exception: "+e,e);
> >> }
> >> Assert.assertTrue("Autz queue receiver did not work", ex ==
> >> null);
> >>
> >>
> >> }finally {
> >> try {
> >> sub1.close();
> >> }catch(Exception ex) {
> >>
> >> }
> >> }
> >> }
> >>
> >> public void runAuzInvalidQueueBrowser() throws Exception {
> >> QueueWorker sub1 = null;
> >> try {
> >>
> >> IntRangeMessageFilter f1 = new
> >> IntRangeMessageFilter(javax.jms.Message.class,
> >>
> >> "USER_NR",
> >> 0,
> >> 1);
> >> sub1 = new QueueWorker(GETTER,
> >> TRANS_NONE,
> >> f1);
> >>
> >> sub1.setUser("nobody", "nobody");
> >> sub1.connect();
> >> Exception ex = null;
> >> try {
> >> sub1.browse();
> >> }catch(Exception e){
> >> ex =e;
> >> }
> >> Assert.assertTrue("Unautz queue receiver throw wrong
> >> exception: " +ex, ex instanceof javax.jms.JMSSecurityException);
> >>
> >>
> >> }finally {
> >> try {
> >> sub1.close();
> >> }catch(Exception ex) {
> >>
> >> }
> >> }
> >> }
> >>
> >> public void runValidPreconfDurSub() throws Exception {
> >> TopicWorker sub1 = null;
> >> TopicWorker pub1 = null;
> >> try {
> >> // Clean testarea up
> >> drainTopic();
> >>
> >> int ic = getIterationCount();
> >>
> >> // Set up a durable subscriber
> >> IntRangeMessageFilter f1 = new
> >> IntRangeMessageFilter(javax.jms.Message.class,
> >>
> >> "DURABLE_NR",
> >> 0,
> >> ic);
> >>
> >> sub1 = new TopicWorker(SUBSCRIBER,
> >> TRANS_NONE,
> >> f1);
> >> sub1.setDurable("john", "needle", "sub2");
> >> Thread t1 = new Thread(sub1);
> >> t1.start();
> >>
> >> // Let is take some time to really set up the dur sub
> >> sleep(2000);
> >> // Publish
> >> IntRangeMessageCreator c1 = new
> >> IntRangeMessageCreator("DURABLE_NR",
> >> 0);
> >> pub1 = new TopicWorker(PUBLISHER,
> >> TRANS_NONE,
> >> c1,
> >> ic);
> >> pub1.connect();
> >> pub1.publish();
> >>
> >> Assert.assertEquals("Publisher did not publish correct
> number
> >> of messages "+pub1.getMessageHandled(),
> >> ic,
> >> pub1.getMessageHandled());
> >>
> >> // let sub1 have some time to handle the messages.
> >> log.debug("Sleeping for " + ((ic*100)/60000) + " minutes");
> >> sleep(ic*100);
> >>
> >> Exception ex = sub1.getException();
> >> if (ex != null)
> >> log.error("ValidPreconfDurSub got an exception: "
> +ex,ex);
> >> Assert.assertTrue("ValidPreconfDurSub did not work", ex ==
> >> null);
> >>
> >> Assert.assertEquals("Subscriber did not get correct number
> of
> >> messages "+sub1.getMessageHandled(),
> >> ic,
> >> sub1.getMessageHandled());
> >>
> >>
> >> t1.stop();
> >> }finally{
> >> try {
> >> pub1.close();
> >> }catch(Exception ex) {}
> >> try {
> >> // if this stops working it might be that we have become
> >> spec
> >> // compliant an do not allow unsubscribe with an open
> >> consumer.
> >> sub1.unsubscribe();
> >> sub1.close();
> >> }catch(Exception ex) {}
> >> }
> >> }
> >>
> >> public void runInvalidPreconfDurSub() throws Exception {
> >> TopicWorker sub1 = null;
> >> try {
> >> // Clean testarea up
> >> TEST_TOPIC ="topic/securedTopic";
> >> //drainTopic();
> >>
> >> int ic = getIterationCount();
> >>
> >> // Set up a durable subscriber
> >> IntRangeMessageFilter f1 = new
> >> IntRangeMessageFilter(javax.jms.Message.class,
> >>
> >> "DURABLE_NR",
> >> 0,
> >> ic);
> >>
> >> sub1 = new TopicWorker(SUBSCRIBER,
> >> TRANS_NONE,
> >> f1);
> >> sub1.setDurable("john", "needle", "sub3");
> >> Thread t1 = new Thread(sub1);
> >> t1.start();
> >>
> >> // Let is take some time to really set up the dur sub
> >> sleep(2000);
> >>
> >> Exception ex = sub1.getException();
> >> Assert.assertTrue("InvalidPreconfDurSub did not get correct
> >> exception:" +ex, ex instanceof javax.jms.JMSSecurityException);
> >>
> >> t1.stop();
> >> }finally{
> >> try {
> >>
> >> sub1.close();
> >> }catch(Exception ex) {}
> >> }
> >> }
> >> public void runValidDynDurSub() throws Exception {
> >> TopicWorker sub1 = null;
> >> TopicWorker pub1 = null;
> >> try {
> >> // Clean testarea up
> >> drainTopic();
> >>
> >> int ic = getIterationCount();
> >>
> >> // Set up a durable subscriber
> >> IntRangeMessageFilter f1 = new
> >> IntRangeMessageFilter(javax.jms.Message.class,
> >>
> >> "DURABLE_NR",
> >> 0,
> >> ic);
> >>
> >> sub1 = new TopicWorker(SUBSCRIBER,
> >> TRANS_NONE,
> >> f1);
> >> sub1.setDurable("dynsub", "dynsub", "sub4");
> >> sub1.setClientID("myId");
> >> Thread t1 = new Thread(sub1);
> >> t1.start();
> >>
> >> // Let is take some time to really set up the dur sub
> >> sleep(2000);
> >>
> >> // Publish
> >> IntRangeMessageCreator c1 = new
> >> IntRangeMessageCreator("DURABLE_NR",
> >> 0);
> >> pub1 = new TopicWorker(PUBLISHER,
> >> TRANS_NONE,
> >> c1,
> >> ic);
> >> pub1.connect();
> >> pub1.publish();
> >>
> >> Assert.assertEquals("Publisher did not publish correct
> number
> >> of messages "+pub1.getMessageHandled(),
> >> ic,
> >> pub1.getMessageHandled());
> >>
> >> // let sub1 have some time to handle the messages.
> >> log.debug("Sleeping for " + ((ic*100)/60000) + " minutes");
> >> sleep(ic*100);
> >>
> >> Exception ex = sub1.getException();
> >> if (ex != null)
> >> log.error("ValidDynDurSub got an exception: " +ex,ex);
> >> Assert.assertTrue("ValidDynDurSub did not work", ex ==
> null);
> >>
> >> Assert.assertEquals("Subscriber did not get correct number
> of
> >> messages "+sub1.getMessageHandled(),
> >> ic,
> >> sub1.getMessageHandled());
> >>
> >>
> >> t1.stop();
> >> }finally{
> >> try {
> >> pub1.close();
> >> }catch(Exception ex) {}
> >> try {
> >> // if this stops working it might be that we have become
> >> spec
> >> // compliant an do not allow unsubscribe with an open
> >> consumer.
> >> sub1.unsubscribe();
> >> sub1.close();
> >> }catch(Exception ex) {}
> >> }
> >> }
> >>
> >> public void runInvalidDynDurSub() throws Exception {
> >> TopicWorker sub1 = null;
> >> try {
> >> // Clean testarea up
> >> TEST_TOPIC ="topic/securedTopic";
> >> //drainTopic();
> >>
> >> int ic = getIterationCount();
> >>
> >> // Set up a durable subscriber
> >> IntRangeMessageFilter f1 = new
> >> IntRangeMessageFilter(javax.jms.Message.class,
> >>
> >> "DURABLE_NR",
> >> 0,
> >> ic);
> >>
> >> sub1 = new TopicWorker(SUBSCRIBER,
> >> TRANS_NONE,
> >> f1);
> >> sub1.setDurable("dynsub", "dynsub", "sub5");
> >> sub1.setClientID("myId2");
> >> Thread t1 = new Thread(sub1);
> >> t1.start();
> >>
> >> // Let is take some time to really set up the dur sub
> >> sleep(2000);
> >>
> >> Exception ex = sub1.getException();
> >> Assert.assertTrue("InvalidDynDurSub did not get correct
> >> exception:" +ex, ex instanceof javax.jms.JMSSecurityException);
> >>
> >> t1.stop();
> >> }finally{
> >> try {
> >> sub1.close();
> >> }catch(Exception ex) {}
> >> }
> >> }
> >> public static junit.framework.Test suite() throws Exception{
> >>
> >> TestSuite suite= new TestSuite();
> >> suite.addTest(new SecurityTestCase("runLoginTest"));
> >> // Authentication tests
> >> suite.addTest(new SecurityTestCase("runLoginNoCred"));
> >> suite.addTest(new SecurityTestCase("runLoginValidCred"));
> >> suite.addTest(new SecurityTestCase("runLoginInvalidPwd"));
> >> suite.addTest(new SecurityTestCase("runLoginInvalidCred"));
> >> // ClientID tests
> >> suite.addTest(new SecurityTestCase("runClientIDNormalTest"));
> >> suite.addTest(new SecurityTestCase("runClientIDPreconfTest"));
> >> suite.addTest(new SecurityTestCase("runClientIDSetTest"));
> >> suite.addTest(new SecurityTestCase("runClientIDSetInternal"));
> >> suite.addTest(new SecurityTestCase("runClientIDSetSteelPreconf"));
> >> suite.addTest(new SecurityTestCase("runClientIDSetAfterInvoke"));
> >> // Autorization tests
> >> suite.addTest(new SecurityTestCase("runAuzValidTopicPublisher"));
> >> suite.addTest(new SecurityTestCase("runAuzInvalidTopicPublisher"));
> >> suite.addTest(new SecurityTestCase("runAuzValidTopicSubscriber"));
> >> suite.addTest(new SecurityTestCase("runAuzInvalidTopicSubscriber"));
> >> suite.addTest(new SecurityTestCase("runAuzValidQueueSender"));
> >> suite.addTest(new SecurityTestCase("runAuzInvalidQueueSender"));
> >> suite.addTest(new SecurityTestCase("runAuzValidQueueReceiver"));
> >> suite.addTest(new SecurityTestCase("runAuzInvalidQueueReceiver"));
> >> suite.addTest(new SecurityTestCase("runAuzValidQueueBrowser"));
> >> suite.addTest(new SecurityTestCase("runAuzInvalidQueueBrowser"));
> >> suite.addTest(new SecurityTestCase("runValidPreconfDurSub"));
> >> suite.addTest(new SecurityTestCase("runInvalidPreconfDurSub"));
> >> suite.addTest(new SecurityTestCase("runValidDynDurSub"));
> >> suite.addTest(new SecurityTestCase("runInvalidDynDurSub"));
> >> //suite.addTest(new DurableSubscriberTest("testBadClient"));
> >> return suite;
> >> }
> >> public static void main(String[] args) {
> >>
> >> }
> >>
> >> } // SecurityTest
> >>
> >>
> >>
> >>
> >> _______________________________________________
> >> Jboss-development mailing list
> >> [EMAIL PROTECTED]
> >> https://lists.sourceforge.net/lists/listinfo/jboss-development
> >>
> >>
> >
> > _______________________________________________
> > Jboss-development mailing list
> > [EMAIL PROTECTED]
> > https://lists.sourceforge.net/lists/listinfo/jboss-development
>
> --
> ------------------------------------------------------------
> Peter Antman Technology in Media, Box 34105 100 26 Stockholm
> Systems Architect WWW: http://www.tim.se
> Email: [EMAIL PROTECTED] WWW: http://www.backsource.org
> Phone: +46-(0)8-506 381 11 Mobile: 070-675 3942
> ------------------------------------------------------------
>
>
> _______________________________________________
> Jboss-development mailing list
> [EMAIL PROTECTED]
> https://lists.sourceforge.net/lists/listinfo/jboss-development
>
>
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
