Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Restore test disabled by mistake

This commit is contained in:
Timothy Bish 2014-12-09 16:15:05 -05:00
parent 12481abb98
commit 90afa24549
1 changed files with 25 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
activemq-amqp/src/test/java/org/apache/activemq/transport/amqp/JMSClientTest.java
View File

@ -108,36 +108,36 @@ public class JMSClientTest extends JMSClientTestSupport {
}
}
@Test // (timeout=30000)
@Test(timeout=30000)
public void testAnonymousProducerConsume() throws Exception {
ActiveMQAdmin.enableJMSFrameTracing();
connection = createConnection();
{
// Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
// Queue queue1 = session.createQueue(getDestinationName() + "1");
// Queue queue2 = session.createQueue(getDestinationName() + "2");
// MessageProducer p = session.createProducer(null);
//
// TextMessage message = session.createTextMessage();
// message.setText("hello");
// p.send(queue1, message);
// p.send(queue2, message);
//
// {
// MessageConsumer consumer = session.createConsumer(queue1);
// Message msg = consumer.receive(TestConfig.TIMEOUT);
// assertNotNull(msg);
// assertTrue(msg instanceof TextMessage);
// consumer.close();
// }
// {
// MessageConsumer consumer = session.createConsumer(queue2);
// Message msg = consumer.receive(TestConfig.TIMEOUT);
// assertNotNull(msg);
// assertTrue(msg instanceof TextMessage);
// consumer.close();
// }
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Queue queue1 = session.createQueue(getDestinationName() + "1");
Queue queue2 = session.createQueue(getDestinationName() + "2");
MessageProducer p = session.createProducer(null);
TextMessage message = session.createTextMessage();
message.setText("hello");
p.send(queue1, message);
p.send(queue2, message);
{
MessageConsumer consumer = session.createConsumer(queue1);
Message msg = consumer.receive(TestConfig.TIMEOUT);
assertNotNull(msg);
assertTrue(msg instanceof TextMessage);
consumer.close();
}
{
MessageConsumer consumer = session.createConsumer(queue2);
Message msg = consumer.receive(TestConfig.TIMEOUT);
assertNotNull(msg);
assertTrue(msg instanceof TextMessage);
consumer.close();
}
}
}