You could do something like this:
for (String queueName :
broker.getJMSServerManager().getActiveMQServer().getActiveMQServerControl().getQueueNames())
{
((QueueControl)broker.getJMSServerManager().getActiveMQServer().getManagementService().getResource(ResourceNames.QUEUE
+ queueName)).removeMessages(null);
}
I didn't compile this so there may be some errors, but I think you get the
idea.
Justin
On Wed, Oct 25, 2017 at 8:05 AM, preben <preben.asmus...@gmail.com> wrote:
> Im switching from Activemq to Artemis and have to migrate some unittests
>
> I got a activemq baseclass like ->
>
> @Before
> public void startEmbeddedBroker() throws Exception {
> broker = new BrokerService();
> TransportConnector connector =
> broker.addConnector("tcp://localhost:61616");
> broker.setPersistent(false);
> broker.setUseJmx(true);
> broker.deleteAllMessages();
> broker.start();
> broker.waitUntilStarted();
> ActiveMQConnectionFactory connFactory = new
> ActiveMQConnectionFactory(connector.getConnectUri() +
> "?jms.prefetchPolicy.all=1");
> connection = connFactory.createConnection();
> connection.start();
> }
>
> @After
> public void stopEmbeddedBroker() throws Exception {
> // wait a bit to let client connections get act's before shutdown
> Thread.sleep(2000);
> connection.stop();
> broker.stop();
> }
>
> That work well for activemq.
> The artemis test baseclass is refactored to ->
>
> @Before
> public void startEmbeddedBroker() throws Exception {
> FileUtils.deleteQuietly(new File("target/data"));
> broker = new EmbeddedJMS();
> brokerUri = "tcp://localhost:61616";
> configureBroker(this.broker);
> startBroker();
> }
>
> protected void configureBroker(EmbeddedJMS broker) throws Exception {
> Configuration configuration = new ConfigurationImpl()
> .setPersistenceEnabled(false)
> .setJournalDirectory("target/data/journal")
> .setSecurityEnabled(false)
> .addAcceptorConfiguration("connector", brokerUri +
> "?protocols=CORE")
> .addConnectorConfiguration("connector", new
> TransportConfiguration(NettyConnectorFactory.class.getName()));
>
> JMSConfiguration jmsConfig = new JMSConfigurationImpl();
>
> ConnectionFactoryConfiguration cfConfig = new
> ConnectionFactoryConfigurationImpl()
> .setName("cf").setConnectorNames(Arrays.asList("connector"))
> .setBindings("cf");
> jmsConfig.getConnectionFactoryConfigurations().add(cfConfig);
>
>
> broker.setConfiguration(configuration).setJmsConfiguration(jmsConfig);
> }
>
> private void startBroker() throws Exception {
> broker.start();
> }
>
> @After
> public void stopEmbeddedBroker() throws Exception {
> broker.stop();
> broker = null;
> }
>
> The only thing missing is the ability to purge all queus and topics like
> the
> one for activemq = *broker.deleteAllMessages()*;
>
> Without that it seems like the tests will see messages enqued in previous
> test (if in same test class) ??
>
> How can I purge all messages in Artemis.
>
> /preben
>
>
>
>
>
> --
> Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-
> f2341805.html
>
