//
// The broker starts asynchronously. The runnable is invoked once
// the broker if fully started.
System.out.println("Starting the broker.");
broker.start(new Runnable(){
public void run() {
System.out.println("The broker has now started.");
System.out.println("Press enter to change the broker port...");
}
});