3333 <stringProp name =" script" >import org.apache.activemq.broker.BrokerService;
3434import org.apache.activemq.broker.BrokerFactory;
3535import org.apache.jmeter.util.JMeterUtils;
36- import org.apache.commons.io.FileUtils;
37- import java.io.File;
36+ import java.nio.file.Path;
37+ import kotlin.io.path.PathsKt;
38+
39+ Path activemqData = Path.of(JMeterUtils.getJMeterHome(), " bin/activemq-data" );
40+ log.info(" Deleting {}" , activemqData);
41+ PathsKt.deleteRecursively(activemqData);
3842
39- File file = new File(JMeterUtils.getJMeterHome(), " bin/activemq-data" );
40- log.info(" Deleting {}" , file);
41- FileUtils.deleteDirectory(file);
4243log.info(" Creating activemq config from {}" , JMeterUtils.getJMeterHome()+ " /bin/testfiles/activemq.xml" );
4344try {
4445 String path = JMeterUtils.getJMeterHome()+ " /bin/testfiles/activemq.xml" ;
@@ -120,18 +121,18 @@ import org.slf4j.LoggerFactory;
120121import javax.naming.InitialContext;
121122import javax.naming.Context;
122123import java.util.Properties;
123- def thread = Thread.start {
124+ def thread = Thread.start {
124125 Properties props = new Properties();
125126 props.setProperty(Context.INITIAL_CONTEXT_FACTORY, " org.apache.activemq.jndi.ActiveMQInitialContextFactory" );
126- props.setProperty(Context.PROVIDER_URL," tcp://127.0.0.1:61616" );
127+ props.setProperty(Context.PROVIDER_URL," tcp://127.0.0.1:61616" );
127128 Context namingCtx = new InitialContext(props);
128129 ConnectionFactory cf = (ConnectionFactory)namingCtx.lookup(" ConnectionFactory" );
129130 Connection con = cf.createConnection();
130131 log.info(" Creating connection to " +Parameters);
131132 Destination dest = (Destination)namingCtx.lookup(Parameters);
132133
133134 try {
134- Session session =
135+ Session session =
135136 con.createSession(false, Session.AUTO_ACKNOWLEDGE); // non-transacted session (more)
136137 MessageConsumer consumer = session.createConsumer(dest);
137138 consumer.setMessageListener(new MyMessageListener(session));
@@ -141,7 +142,7 @@ def thread = Thread.start {
141142 session.close();
142143 log.info(" Closed session" );
143144 } finally {
144- con.close(); // free all resources (more)
145+ con.close(); // free all resources (more)
145146 }
146147}
147148SampleResult.setResponseMessageOK();
@@ -400,7 +401,7 @@ Connection con = cf.createConnection();
400401Destination dest = (Destination)namingCtx.lookup(" dynamicQueues/requestQueue4" );
401402
402403try {
403- Session session =
404+ Session session =
404405 con.createSession(false, Session.AUTO_ACKNOWLEDGE); // non-transacted session (more)
405406
406407 MessageConsumer consumer = session.createConsumer(dest);
@@ -1396,7 +1397,8 @@ propFloat 1.2</stringProp>
13961397 <stringProp name =" cacheKey" >true</stringProp >
13971398 <stringProp name =" script" >import org.apache.activemq.broker.BrokerService;
13981399import org.apache.jmeter.util.JMeterUtils;
1399- import org.apache.commons.io.FileUtils;
1400+ import java.nio.file.Path;
1401+ import kotlin.io.path.PathsKt;
14001402
14011403BrokerService broker = props.get(" ACTIVEMQ_BROKER" );
14021404Thread.start {
@@ -1406,7 +1408,7 @@ Thread.start {
14061408 // Otherwise " The following non-daemon threads are still running" is printed
14071409 sleep(700)
14081410 broker.stop()
1409- FileUtils.deleteDirectory(new File (JMeterUtils.getJMeterHome(), " bin/activemq-data" ))
1411+ PathsKt.deleteRecursively(Path.of (JMeterUtils.getJMeterHome(), " bin/activemq-data" ))
14101412}
14111413</stringProp >
14121414 </JSR223Sampler >
0 commit comments