//START SNIPPET: broker
public void run() {
try {
broker = new BrokerService();
broker.setPersistenceAdapter(new MemoryPersistenceAdapter());
broker.setTmpDataDirectory(new File("./target"));
broker.addConnector(brokerUrl1);
broker.start();
} catch (Exception e) {
e.printStackTrace();