User: user57
Date: 01/07/05 00:05:59
Modified: src/main/org/jboss/test/mdb/test Main.java
Log:
Revision Changes Path
1.6 +138 -138 jbosstest/src/main/org/jboss/test/mdb/test/Main.java
Index: Main.java
===================================================================
RCS file: /cvsroot/jboss/jbosstest/src/main/org/jboss/test/mdb/test/Main.java,v
retrieving revision 1.5
retrieving revision 1.6
diff -u -r1.5 -r1.6
--- Main.java 2001/05/07 19:27:23 1.5
+++ Main.java 2001/07/05 07:05:59 1.6
@@ -18,192 +18,192 @@
package org.jboss.test.mdb.test;
import javax.naming.*;
-
import javax.jms.*;
-import org.jboss.test.mdb.bean.CustomMessage;
-
-import org.jboss.test.util.Deploy;
import junit.framework.Test;
import junit.framework.TestCase;
import junit.framework.TestSuite;
+
+import org.jboss.test.mdb.bean.CustomMessage;
+
+import org.jboss.test.util.Deploy;
+
//import org.jboss.jms.jndi.*;
/**
- * Main.java
- *
* Some simple tests of MDB. These could be much more aloborated.
+ *
+ * In the future at least the following tests should be done some how:
+ * <ol>
+ * <li>Queue
+ * <li>Topic
+ * <li>Durable topic
+ * <li>Bean TX - with AUTO_ACK and DUPS_OK
+ * <li>CMT Required
+ * <li>CMT NotSupported
+ * <li>Selector
+ * <li>User and password login
+ * <li>Al the stuff with the context
+ * </ol>
*
- * In the future at least the following tests should be done some how
- 1. Queue
- 2. Topic
- 3. Durable topic
- 4. Bean TX - with AUTO_ACK and DUPS_OK
- 5. CMT Required
- 6. CMT NotSupported
- 7. Selector
- 8. User and password login
- 9. Al the stuff with the context
- * Created: Fri Dec 29 16:53:26 2000
+ * <p>Created: Fri Dec 29 16:53:26 2000
*
- * @author
- * @version
+ * @author <a href="mailto:[EMAIL PROTECTED]";>Peter Antman</a>
+ * @author <a href="mailto:[EMAIL PROTECTED]";>Jason Dillon</a>
+ * @version <pre>$Revision: 1.6 $</pre>
*/
-
-public class Main extends TestCase {
+public class Main
+ extends TestCase
+{
// Static --------------------------------------------------------
static boolean deployed = false;
// Provider specific
static String TOPIC_FACTORY = "TopicConnectionFactory";
- static String QUEUE_FACTORY ="QueueConnectionFactory";
+ static String QUEUE_FACTORY = "QueueConnectionFactory";
QueueConnection queueConnection;
TopicConnection topicConnection;
- //JMSProviderAdapter providerAdapter;
+ // JMSProviderAdapter providerAdapter;
Context context;
String dest;
- public Main(String name, String dest) throws Exception{
- super(name);
- this.dest = dest;
- //Get JMS JNDI Adapter
- //Class cls = Class.forName(providerAdapterClass);
- //providerAdapter = (JMSProviderAdapter)cls.newInstance();
- context = new InitialContext();
- // This is not completly clean since it still have to use
- // provider specific queue and topic names!!
-
+ public Main(String name, String dest) throws Exception {
+ super(name);
+ this.dest = dest;
+ // Get JMS JNDI Adapter
+ // Class cls = Class.forName(providerAdapterClass);
+ // providerAdapter = (JMSProviderAdapter)cls.newInstance();
+ context = new InitialContext();
+ // This is not completly clean since it still have to use
+ // provider specific queue and topic names!!
+ }
+
+ protected void setUp() throws Exception {
+ // test methods call getXXXSession() to create session & connection
+ }
+
+ protected void tearDown() throws Exception {
+ if (topicConnection != null) {
+ topicConnection.close();
+ }
+ if (queueConnection != null) {
+ queueConnection.close();
+ }
}
-
+
protected void printHeader() {
System.out.println("\n---- Testing method " + name() +
- " for destination " +dest);
+ " for destination " +dest);
}
+ private QueueSession getQueueSession() throws Exception {
+ if (queueConnection == null) {
+ QueueConnectionFactory queueFactory =
+ (QueueConnectionFactory)context.lookup(QUEUE_FACTORY);
+
+ queueConnection = queueFactory.createQueueConnection();
+ }
+ return queueConnection.createQueueSession(false,
+ Session.AUTO_ACKNOWLEDGE);
+ }
+
+ private TopicSession getTopicSession() throws Exception {
+ if (topicConnection == null) {
+ TopicConnectionFactory topicFactory =
+ (TopicConnectionFactory)context.lookup(TOPIC_FACTORY);
+ topicConnection = topicFactory.createTopicConnection();
+ }
+
+ // No transaction & auto ack
+ return topicConnection.createTopicSession(false,
+ Session.AUTO_ACKNOWLEDGE);
+ }
/**
* Test sending messages to Topic testTopic
*/
- public void testQueue()
- throws Exception {
- printHeader();
- QueueSession session = getQueueSession();
- Queue queue = (Queue)context.lookup(dest);
- QueueSender sender = session.createSender(queue);
-
- System.out.println("TestQueue: " + dest + " Sending 10 messages 1-10");
- for (int i = 1; i < 11; i++) {
- TextMessage message = session.createTextMessage();
- message.setText("Queue Message " + dest + " nr " + i);
- sender.send(queue, message);
- }
+ public void testQueue() throws Exception {
+ printHeader();
+ QueueSession session = getQueueSession();
+ Queue queue = (Queue)context.lookup(dest);
+ QueueSender sender = session.createSender(queue);
+
+ System.out.println("TestQueue: " + dest + " Sending 10 messages 1-10");
+ for (int i = 1; i < 11; i++) {
+ TextMessage message = session.createTextMessage();
+ message.setText("Queue Message " + dest + " nr " + i);
+ sender.send(queue, message);
+ }
+
+ sender.close();
}
/**
* Test sending messages to Queue testQueue
*/
public void testTopic() throws Exception {
- printHeader();
- TopicSession session = getTopicSession();
- Topic topic = (Topic)context.lookup(dest);
- TopicPublisher pub = session.createPublisher(topic);
-
- System.out.println("TestTopic: " + dest + ": Sending 10st messages 1-10");
- for (int i = 1; i < 11; i++) {
- TextMessage message = session.createTextMessage();
- message.setText("Topic Message " + dest + " nr " + i);
- pub.publish(topic, message);
- }
+ printHeader();
+ TopicSession session = getTopicSession();
+ Topic topic = (Topic)context.lookup(dest);
+ TopicPublisher pub = session.createPublisher(topic);
+
+ System.out.println("TestTopic: " + dest +
+ ": Sending 10st messages 1-10");
+
+ for (int i = 1; i < 11; i++) {
+ TextMessage message = session.createTextMessage();
+ message.setText("Topic Message " + dest + " nr " + i);
+ pub.publish(topic, message);
+ }
+
+ pub.close();
}
/**
* Test sending messages to queue testObjectMessage
*/
public void testObjectMessage() throws Exception {
- printHeader();
- QueueSession session = getQueueSession();
- // Non portable!!
- Queue queue = (Queue)context.lookup("queue/testObjectMessage");
- QueueSender sender = session.createSender(queue);
-
- System.out.println("TestQueue: Sending 10 messages 1-10");
- for (int i = 1; i < 11; i++) {
- ObjectMessage message = session.createObjectMessage();
- message.setObject(new CustomMessage(i));
- sender.send(queue, message);
- }
- session.close();
- }
+ printHeader();
+ QueueSession session = getQueueSession();
+ // Non portable!!
+ Queue queue = (Queue)context.lookup("queue/testObjectMessage");
+ QueueSender sender = session.createSender(queue);
+
+ System.out.println("TestQueue: Sending 10 messages 1-10");
+ for (int i = 1; i < 11; i++) {
+ ObjectMessage message = session.createObjectMessage();
+ message.setObject(new CustomMessage(i));
+ sender.send(queue, message);
+ }
- private QueueSession getQueueSession() throws Exception {
- if (queueConnection == null) {
- QueueConnectionFactory queueFactory =
- (QueueConnectionFactory)context.lookup(QUEUE_FACTORY);
-
- queueConnection = queueFactory.createQueueConnection();
- }
- return queueConnection.createQueueSession(false,
- Session.AUTO_ACKNOWLEDGE);
- }
-
-
- private TopicSession getTopicSession() throws Exception{
- if (topicConnection == null) {
- TopicConnectionFactory topicFactory =
- (TopicConnectionFactory)context.lookup(TOPIC_FACTORY);
- topicConnection = topicFactory.createTopicConnection();
- }
- return topicConnection.createTopicSession(
- // No transaction
- false,
- // Auto ack
- Session.AUTO_ACKNOWLEDGE);
-
+ sender.close();
+ session.close();
}
-
- protected void setUp()
- throws Exception {
-
- }
-
- protected void tearDown()
- throws Exception {
- if (topicConnection != null)
- topicConnection.close();
- if (queueConnection != null)
- queueConnection.close();
- }
-
- public static Test suite ()
- {
- TestSuite suite = new TestSuite();
+ public static Test suite() {
+ TestSuite suite = new TestSuite();
- try{
- System.out.println("Deploying");
- Deploy.deploy("../deploy/mdb.jar");
-
- System.out.println("Testing Queue publishing");
- suite.addTest(new Main("testObjectMessage",""));
- suite.addTest(new Main("testQueue","queue/testQueue"));
- suite.addTest(new Main("testTopic","topic/testTopic"));
- suite.addTest(new Main("testTopic","topic/testDurableTopic"));
- suite.addTest(new Main("testQueue","queue/ex"));
-
- } catch (Exception ex) {
- ex.printStackTrace();
- System.exit(0);
-
- }
- return suite;
+ try {
+ System.out.println("Deploying...");
+ Deploy.deploy("../deploy/mdb.jar");
+
+ suite.addTest(new Main("testObjectMessage",""));
+ suite.addTest(new Main("testQueue","queue/testQueue"));
+ suite.addTest(new Main("testTopic","topic/testTopic"));
+ suite.addTest(new Main("testTopic","topic/testDurableTopic"));
+ suite.addTest(new Main("testQueue","queue/ex"));
+
+ // add a test case to undeploy our support applications
+ suite.addTest(new Deploy.Undeployer("../deploy/mdb.jar"));
+ }
+ catch (Throwable t) {
+ t.printStackTrace();
+ System.exit(0);
+ }
+
+ return suite;
}
-} // Main
-
-
-
-
-
-
+}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
