1 18 package org.apache.activemq.pool; 19 20 import org.apache.activemq.pool.PooledConnectionFactory; 21 import org.apache.activemq.test.JmsTopicSendReceiveWithTwoConnectionsTest; 22 23 import javax.jms.Connection ; 24 25 28 public class JmsSendReceiveTwoConnectionsWithSenderUsingPoolTest extends JmsTopicSendReceiveWithTwoConnectionsTest { 29 30 protected PooledConnectionFactory senderConnectionFactory = new PooledConnectionFactory("vm://localhost?broker.persistent=false"); 31 32 protected Connection createSendConnection() throws Exception { 33 return senderConnectionFactory.createConnection(); 34 } 35 36 protected void setUp() throws Exception { 37 verbose = true; 38 super.setUp(); 39 } 40 41 protected void tearDown() throws Exception { 42 super.tearDown(); 43 senderConnectionFactory.stop(); 44 } 45 46 } 47 | Popular Tags |