User: pra
Date: 02/03/06 09:34:13
Modified: src/main/org/jboss/test/jbossmq/test
JBossMQUnitTestCase.java
Log:
Some small changes
Revision Changes Path
1.10 +30 -14
jbosstest/src/main/org/jboss/test/jbossmq/test/JBossMQUnitTestCase.java
Index: JBossMQUnitTestCase.java
===================================================================
RCS file:
/cvsroot/jboss/jbosstest/src/main/org/jboss/test/jbossmq/test/JBossMQUnitTestCase.java,v
retrieving revision 1.9
retrieving revision 1.10
diff -u -r1.9 -r1.10
--- JBossMQUnitTestCase.java 16 Feb 2002 10:21:35 -0000 1.9
+++ JBossMQUnitTestCase.java 6 Mar 2002 17:34:13 -0000 1.10
@@ -132,11 +132,15 @@
TextMessage message = session.createTextMessage();
message.setText("Normal message");
- sender.send(queue, message, DeliveryMode.NON_PERSISTENT, 4, 0);
+ sender.send(message, DeliveryMode.NON_PERSISTENT, 4, 0);
+ //sender.send(queue, message, DeliveryMode.NON_PERSISTENT, 4, 0);
message.setText("Persistent message");
- sender.send(queue, message, DeliveryMode.PERSISTENT, 4, 0);
+ sender.send(message, DeliveryMode.PERSISTENT, 4, 0);
+ //sender.send(queue, message, DeliveryMode.PERSISTENT, 4, 0);
message.setText("High Priority Persistent message");
- sender.send(queue, message, DeliveryMode.PERSISTENT, 10, 0);
+ sender.send(message, DeliveryMode.PERSISTENT, 10, 0);
+ //sender.send(queue, message, DeliveryMode.PERSISTENT, 10, 0);
+
//message.setText("Expiring Persistent message");
//sender.send(queue, message, DeliveryMode.NON_PERSISTENT, 4, 1);
@@ -269,11 +273,14 @@
TextMessage message = session.createTextMessage();
message.setText("Normal message");
- sender.send(queue, message, DeliveryMode.NON_PERSISTENT, 4, 0);
+ sender.send(message, DeliveryMode.NON_PERSISTENT, 4, 0);
+ //sender.send(queue, message, DeliveryMode.NON_PERSISTENT, 4, 0);
message.setText("Persistent message");
- sender.send(queue, message, DeliveryMode.PERSISTENT, 4, 0);
+ sender.send( message, DeliveryMode.PERSISTENT, 4, 0);
+ //sender.send(queue, message, DeliveryMode.PERSISTENT, 4, 0);
message.setText("High Priority Persistent message");
- sender.send(queue, message, DeliveryMode.PERSISTENT, 10, 0);
+ sender.send(message, DeliveryMode.PERSISTENT, 10, 0);
+ //sender.send(queue, message, DeliveryMode.PERSISTENT, 10, 0);
try{ Thread.sleep(5*1000); }catch(InterruptedException e){}
@@ -289,17 +296,21 @@
});
message.setText("Persistent message");
- sender.send(queue, message, DeliveryMode.PERSISTENT, 4, 0);
+ sender.send( message, DeliveryMode.PERSISTENT, 4, 0);
+ //sender.send(queue, message, DeliveryMode.PERSISTENT, 4, 0);
message.setText("High Priority Persistent message");
- sender.send(queue, message, DeliveryMode.PERSISTENT, 10, 0);
+ sender.send(message, DeliveryMode.PERSISTENT, 10, 0);
+ //sender.send(queue, message, DeliveryMode.PERSISTENT, 10, 0);
try{ Thread.sleep(5*1000); }catch(InterruptedException e){}
receiver.setMessageListener(null);
message.setText("Persistent message");
- sender.send(queue, message, DeliveryMode.PERSISTENT, 4, 0);
+ sender.send(message, DeliveryMode.PERSISTENT, 4, 0);
+ //sender.send(queue, message, DeliveryMode.PERSISTENT, 4, 0);
message.setText("High Priority Persistent message");
- sender.send(queue, message, DeliveryMode.PERSISTENT, 10, 0);
+ sender.send(message, DeliveryMode.PERSISTENT, 10, 0);
+ //sender.send(queue, message, DeliveryMode.PERSISTENT, 10, 0);
sender.close();
drainQueue();
@@ -308,7 +319,7 @@
}
public void testApplicationServerStuff() throws Exception{
- getLog().debug("Testing app server stuff");
+ getLog().debug("Starting testing app server stuff");
connect();
Queue testQueue = (Queue)context.lookup(TEST_QUEUE);
@@ -351,10 +362,11 @@
try{ Thread.sleep(5*1000); }catch(Exception e){}
disconnect();
- getLog().debug("Done testing app server stuff");
+ getLog().debug("Testing app server stuff passed");
}
public void testPM() throws Exception{
+ getLog().debug("Starting testing pm");
//simply put a few messages on the test queue for next time.
connect();
@@ -367,7 +379,7 @@
sender.close();
session.close();
disconnect();
-
+ getLog().debug("Testing pm stuff passed");
}
private void drainMessagesForTopic(TopicSubscriber sub) throws JMSException{
@@ -508,6 +520,7 @@
public static Test suite() throws Exception
{
TestSuite suite = new TestSuite();
+
suite.addTest(new JBossTestSetup(new TestSuite(JBossMQUnitTestCase.class))
{
protected void setUp() throws Exception
@@ -521,6 +534,7 @@
this.getLog().info("JBossMQUnitTestCase, ConnectionFactory done");
}
});
+
suite.addTest(new JBossTestSetup(new TestSuite(JBossMQUnitTestCase.class))
{
protected void setUp() throws Exception
@@ -534,6 +548,7 @@
this.getLog().info("JBossMQUnitTestCase, UILConnectionFactory done");
}
});
+
suite.addTest(new JBossTestSetup(new TestSuite(JBossMQUnitTestCase.class))
{
protected void setUp() throws Exception
@@ -547,7 +562,8 @@
this.getLog().info("JBossMQUnitTestCase, RMIConnectionFactory done");
}
});
- //in vm won't work ;-)
+
+ //in vm won't work ;-) We have to write an IN VM MBean junit testrunner!
/*suite.addTest(new JBossTestSetup(new TestSuite(JBossMQUnitTestCase.class))
{
protected void setUp() throws Exception
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
