1 18 package org.apache.activemq; 19 import javax.jms.MessageConsumer ; 20 21 22 25 public class JmsQueueSendReceiveMultipleConsumersTest extends JmsQueueSendReceiveTest{ 26 MessageConsumer consumer1; 27 MessageConsumer consumer2; 28 29 protected void setUp() throws Exception { 30 messageCount = 5000; 31 super.setUp(); 32 33 consumer1 = createConsumer(); 34 consumer1.setMessageListener(this); 35 consumer2 = createConsumer(); 36 consumer2.setMessageListener(this); 37 38 } 39 } 40 | Popular Tags |