1 18 package org.apache.activemq; 19 20 import javax.jms.Connection ; 21 import javax.jms.DeliveryMode ; 22 import javax.jms.Destination ; 23 import javax.jms.JMSException ; 24 import javax.jms.MessageConsumer ; 25 import javax.jms.Session ; 26 27 import org.apache.activemq.ActiveMQConnectionFactory; 28 29 32 public class JmsTopicSendReceiveWithTwoConnectionsTest extends JmsSendReceiveTestSupport { 33 34 private static final org.apache.commons.logging.Log log = org.apache.commons.logging.LogFactory 35 .getLog(JmsTopicSendReceiveWithTwoConnectionsTest.class); 36 37 protected Connection sendConnection; 38 protected Connection receiveConnection; 39 protected Session receiveSession; 40 41 protected void setUp() throws Exception { 42 super.setUp(); 43 44 connectionFactory = createConnectionFactory(); 45 46 sendConnection = createSendConnection(); 47 sendConnection.start(); 48 49 receiveConnection = createReceiveConnection(); 50 receiveConnection.start(); 51 52 log.info("Created sendConnection: " + sendConnection); 53 log.info("Created receiveConnection: " + receiveConnection); 54 55 session = sendConnection.createSession(false, Session.AUTO_ACKNOWLEDGE); 56 receiveSession = receiveConnection.createSession(false, Session.AUTO_ACKNOWLEDGE); 57 58 log.info("Created sendSession: " + session); 59 log.info("Created receiveSession: " + receiveSession); 60 61 producer = session.createProducer(null); 62 producer.setDeliveryMode(deliveryMode); 63 64 log.info("Created producer: " + producer + " delivery mode = " + 65 (deliveryMode == DeliveryMode.PERSISTENT ? "PERSISTENT" : "NON_PERSISTENT")); 66 67 if (topic) { 68 consumerDestination = session.createTopic(getConsumerSubject()); 69 producerDestination = session.createTopic(getProducerSubject()); 70 } 71 else { 72 consumerDestination = session.createQueue(getConsumerSubject()); 73 producerDestination = session.createQueue(getProducerSubject()); 74 } 75 76 log.info("Created consumer destination: " + consumerDestination + " of type: " + consumerDestination.getClass()); 77 log.info("Created producer destination: " + producerDestination + " of type: " + producerDestination.getClass()); 78 79 consumer = createConsumer(receiveSession,consumerDestination); 80 consumer.setMessageListener(this); 81 82 83 log.info("Started connections"); 84 } 85 86 protected Connection createReceiveConnection() throws Exception { 87 return createConnection(); 88 } 89 90 protected Connection createSendConnection() throws Exception { 91 return createConnection(); 92 } 93 94 protected MessageConsumer createConsumer(Session session, Destination dest) throws JMSException { 95 return session.createConsumer(dest); 96 } 97 98 protected ActiveMQConnectionFactory createConnectionFactory() throws Exception { 99 return new ActiveMQConnectionFactory("vm://localhost?broker.persistent=false"); 100 } 101 102 protected void tearDown() throws Exception { 103 session.close(); 104 receiveSession.close(); 105 sendConnection.close(); 106 receiveConnection.close(); 107 } 108 } 109 | Popular Tags |