ARTEMIS-3776 just my OCD applying aesthetic tweaks to recediveOW.groovy
This commit is contained in:
parent
bc17acd6da
commit
ccfd4b7a62
|
@ -18,29 +18,29 @@
|
||||||
|
|
||||||
import org.apache.activemq.artemis.tests.compatibility.GroovyRun
|
import org.apache.activemq.artemis.tests.compatibility.GroovyRun
|
||||||
|
|
||||||
import javax.jms.Connection
|
|
||||||
import javax.jms.MessageConsumer
|
import javax.jms.MessageConsumer
|
||||||
import java.util.Date;
|
|
||||||
import java.util.UUID;
|
|
||||||
import javax.jms.ConnectionFactory;
|
|
||||||
import javax.jms.MessageProducer;
|
|
||||||
import javax.jms.Queue;
|
import javax.jms.Queue;
|
||||||
import javax.jms.Session;
|
import javax.jms.Session;
|
||||||
import javax.jms.TextMessage;
|
import javax.jms.TextMessage;
|
||||||
import org.apache.activemq.ActiveMQConnectionFactory;
|
import org.apache.activemq.ActiveMQConnectionFactory;
|
||||||
|
|
||||||
|
{
|
||||||
|
final ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory("failover:(tcp://localhost:61616)");
|
||||||
|
connection = cf.createConnection();
|
||||||
|
try {
|
||||||
|
|
||||||
final ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory("failover:(tcp://localhost:61616)");
|
final int numberOfMessages = Integer.parseInt(arg[0])
|
||||||
connection = cf.createConnection();
|
final Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
|
||||||
final int numberOfMessages = Integer.parseInt(arg[0])
|
final Queue queue = session.createQueue("Test");
|
||||||
final Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
|
final MessageConsumer consumer = session.createConsumer(queue)
|
||||||
final Queue queue = session.createQueue("Test");
|
connection.start();
|
||||||
final MessageConsumer consumer = session.createConsumer(queue)
|
|
||||||
connection.start();
|
|
||||||
|
|
||||||
for (int i = 0; i < numberOfMessages; i++) {
|
for (int i = 0; i < numberOfMessages; i++) {
|
||||||
final TextMessage tm = (TextMessage)consumer.receive(1000);
|
final TextMessage tm = (TextMessage) consumer.receive(1000);
|
||||||
GroovyRun.assertNotNull(tm)
|
GroovyRun.assertNotNull(tm)
|
||||||
GroovyRun.assertEquals("m" + i, tm.getText());
|
GroovyRun.assertEquals("m" + i, tm.getText());
|
||||||
}
|
}
|
||||||
connection.close();
|
} finally {
|
||||||
|
connection.close();
|
||||||
|
}
|
||||||
|
}
|
|
@ -50,4 +50,4 @@ import org.apache.activemq.artemis.jms.client.ActiveMQJMSConnectionFactory;
|
||||||
finally {
|
finally {
|
||||||
if (c != null) c.close();
|
if (c != null) c.close();
|
||||||
}
|
}
|
||||||
}
|
}
|
Loading…
Reference in New Issue