package com.redhat.support.examples;

import org.eclipse.paho.mqttv5.client.MqttClient;
import org.eclipse.paho.mqttv5.client.MqttConnectionOptions;
import org.eclipse.paho.mqttv5.client.persist.MemoryPersistence;
import org.junit.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class DestinationCleanupTest {

    static final Logger logger = LoggerFactory.getLogger(DestinationCleanupTest.class);

    @Test
    public void testAmqpMqtt() throws Exception {

        String mqttUrl = "tcp://localhost:1883";
        String username = "admin";
        String password = "admin";

        MqttConnectionOptions options = new MqttConnectionOptions();;
        options.setCleanStart(true);
        options.setUserName(username);
        options.setPassword((password).getBytes());
        MqttClient testClient = new MqttClient(mqttUrl, "test-client-0", new MemoryPersistence());
        testClient.setTimeToWait(10000);
        testClient.connect(options);
        testClient.publish("foo/bar", "test".getBytes(), 1, false);
        testClient.disconnect();
    }
}

         <address-setting match="#">
...
            <auto-delete-queues>true</auto-delete-queues>
	    <auto-delete-queues-delay>0</auto-delete-queues-delay>
            <auto-delete-addresses>true</auto-delete-addresses>
            <auto-delete-addresses-delay>0</auto-delete-addresses-delay>
...
          </address-setting>