@Before
public void init() throws Exception{
conFactory= new ActiveMQConnectionFactory("admin", PASSWORD, String.format("tcp:, HOST, PORT));
conn = conFactory.createConnection();
session = conn.createSession(false,Session.AUTO_ACKNOWLEDGE);
conn.start();
}
@Test
public void manyQueueTest() throws JMSException {
for (int i = 0; i < 500; i++) {
Destination queue=session.createQueue(TEST_QUEUE + i);
MessageProducer producer=session.createProducer(queue);
Message m=session.createTextMessage(TEST_MESSAGE+i);
producer.send(session.createTextMessage("i")); producer.close();
}
@After
public void closeConnection() throws JMSException {
session.close();
conn.close();
}