User: kimptoc
Date: 01/05/20 05:29:11
Modified: src/main/org/jboss/test/jmsra/test RaTest.java
Log:
removed setUp call from ctor - it gets called before each test anyway
Revision Changes Path
1.2 +67 -62 jbosstest/src/main/org/jboss/test/jmsra/test/RaTest.java
Index: RaTest.java
===================================================================
RCS file: /cvsroot/jboss/jbosstest/src/main/org/jboss/test/jmsra/test/RaTest.java,v
retrieving revision 1.1
retrieving revision 1.2
diff -u -r1.1 -r1.2
--- RaTest.java 2001/05/06 01:13:18 1.1
+++ RaTest.java 2001/05/20 12:29:11 1.2
@@ -5,12 +5,12 @@
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2 of the License, or (at your option) any later version
- *
+ *
* This library is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
- *
+ *
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
@@ -30,11 +30,12 @@
*
* Created: Mon Apr 23 21:35:25 2001
*
- * @author
+ * @author
* @version
*/
-public class RaTest extends junit.framework.TestCase implements MessageListener{
+public class RaTest extends junit.framework.TestCase implements MessageListener
+{
private String QUEUE_FACTORY = "QueueConnectionFactory";
private String QUEUE = "queue/testQueue";
@@ -47,93 +48,97 @@
private String n;
public RaTest(String name, String beanJNDI) throws Exception {
- super(name);
- n = name;
- this.beanJNDI = beanJNDI;
- setUp();
+ super(name);
+ n = name;
+ this.beanJNDI = beanJNDI;
}
protected void printHeader() {
- System.out.println("\n---- Testing method " + n +
- " for bean " + beanJNDI);
+ System.out.println("\n---- Testing method " + n +
+ " for bean " + beanJNDI);
}
protected void printOK() {
- System.out.println("Test OK\n----");
+ System.out.println("Test OK\n----");
}
protected void setUp() throws Exception {
- // Get publisher
- Context context = new InitialContext();
- PublisherHome publisherH = (PublisherHome)context.lookup(beanJNDI);
- publisher = publisherH.create();
-
- QueueConnectionFactory factory = (QueueConnectionFactory)
- context.lookup(QUEUE_FACTORY);
- queueConnection = factory.createQueueConnection();
- queueSession = queueConnection.createQueueSession(false,
Session.AUTO_ACKNOWLEDGE);
- queue = (Queue)context.lookup(QUEUE);
- queueReceiver = queueSession.createReceiver(queue);
- //queueSession.setMessageListener(this);
- queueConnection.start();
+ // Get publisher
+ Context context = new InitialContext();
+ PublisherHome publisherH = (PublisherHome)context.lookup(beanJNDI);
+ publisher = publisherH.create();
+
+ QueueConnectionFactory factory = (QueueConnectionFactory)
+ context.lookup(QUEUE_FACTORY);
+ queueConnection = factory.createQueueConnection();
+ queueSession = queueConnection.createQueueSession(false,
Session.AUTO_ACKNOWLEDGE);
+ queue = (Queue)context.lookup(QUEUE);
+ queueReceiver = queueSession.createReceiver(queue);
+ //queueSession.setMessageListener(this);
+ queueConnection.start();
}
/**
* Check if we got a message
*/
private int getJmsMessage() throws Exception {
- Message m = queueReceiver.receive(5000L);
- if(m != null) {
- System.out.println("Recived message");
- return m.getIntProperty(Publisher.JMS_MESSAGE_NR);
- } else {
- System.out.println("NO message recived");
- return -1;
- }
+ Message m = queueReceiver.receive(5000L);
+ if (m != null)
+ {
+ System.out.println("Recived message");
+ return m.getIntProperty(Publisher.JMS_MESSAGE_NR);
+ } else
+ {
+ System.out.println("NO message recived");
+ return -1;
+ }
}
-
+
public void testSimple() throws Exception {
- printHeader();
- System.out.println("Verify simple send of message");
- publisher.simple(1);
-
- assert(1 == getJmsMessage() );
- printOK();
+ printHeader();
+ System.out.println("Verify simple send of message");
+ publisher.simple(1);
+
+ assert(1 == getJmsMessage() );
+ printOK();
}
public void testSimpleFail() throws Exception {
- printHeader();
- System.out.println("Verify simple failed transaction");
- publisher.simpleFail(2);
-
- assert(-1 == getJmsMessage() );
- printOK();
+ printHeader();
+ System.out.println("Verify simple failed transaction");
+ publisher.simpleFail(2);
+
+ assert(-1 == getJmsMessage() );
+ printOK();
}
public void testBeanOk() throws Exception {
- printHeader();
- System.out.println("Verify bean ok");
- publisher.beanOk(3);
-
- assert(3 == getJmsMessage() );
- printOK();
+ printHeader();
+ System.out.println("Verify bean ok");
+ publisher.beanOk(3);
+
+ assert(3 == getJmsMessage() );
+ printOK();
}
public void testBeanError() throws Exception {
- printHeader();
- System.out.println("Verify bean eroor failed transaction");
- try {
- publisher.beanError(4);
- }catch(Exception ex) {}
-
- assert(-1 == getJmsMessage() );
- printOK();
+ printHeader();
+ System.out.println("Verify bean eroor failed transaction");
+ try
+ {
+ publisher.beanError(4);
+ } catch (Exception ex)
+ {
+ }
+
+ assert(-1 == getJmsMessage() );
+ printOK();
}
public void onMessage(Message message) {
- System.out.println("Got message");
+ System.out.println("Got message");
}
public static void main(String[] args) {
-
+
}
-
+
} // RaTest
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
http://lists.sourceforge.net/lists/listinfo/jboss-development
