1 22 package org.jboss.test.jmsra.test; 23 import javax.jms.MessageConsumer ; 24 import javax.jms.Queue ; 25 import javax.jms.QueueConnection ; 26 27 import javax.jms.QueueConnectionFactory ; 28 import javax.jms.QueueSession ; 29 import javax.jms.Session ; 30 31 import javax.management.ObjectName ; 32 33 import javax.naming.Context ; 34 35 import junit.framework.Test; 36 37 import org.jboss.test.JBossTestSetup; 38 39 48 public class RaQueueUnitTestCase 49 extends RaTest 50 { 51 private final static String QUEUE_FACTORY = "ConnectionFactory"; 52 private final static String QUEUE = "queue/testQueue"; 53 private final static String JNDI = "TxPublisher"; 54 55 61 public RaQueueUnitTestCase(String name) throws Exception 62 { 63 super(name, JNDI); 64 } 65 66 72 protected void init(final Context context) throws Exception 73 { 74 QueueConnectionFactory factory = 75 (QueueConnectionFactory )context.lookup(QUEUE_FACTORY); 76 77 connection = factory.createQueueConnection(); 78 79 session = ((QueueConnection )connection).createQueueSession(false, Session.AUTO_ACKNOWLEDGE); 80 81 Queue queue = (Queue )context.lookup(QUEUE); 82 83 consumer = ((QueueSession )session).createReceiver(queue); 84 } 85 86 public static Test suite() throws Exception 87 { 88 return new JBossTestSetup(getDeploySetup(RaQueueUnitTestCase.class, "jmsra.jar")) 89 { 90 protected void setUp() throws Exception 91 { 92 super.setUp(); 93 ClassLoader loader = Thread.currentThread().getContextClassLoader(); 94 deploy (loader.getResource("messaging/test-destinations-service.xml").toString()); 95 } 96 97 protected void tearDown() throws Exception 98 { 99 super.tearDown(); 100 101 getServer().invoke 103 ( 104 new ObjectName ("jboss.mq.destination:service=Queue,name=testQueue"), 105 "removeAllMessages", 106 new Object [0], 107 new String [0] 108 ); 109 ClassLoader loader = Thread.currentThread().getContextClassLoader(); 110 undeploy (loader.getResource("messaging/test-destinations-service.xml").toString()); 111 } 112 }; 113 } 114 115 116 } 117 | Popular Tags |