Broker ACtiveMQ

Broker.java

package com.bahadirakin.jms;

import org.apache.activemq.broker.BrokerService;

/**
 * @author bahadir.akin
 * 
 */
public class Broker {
	public static void main(String[] args) {
		BrokerService broker = new BrokerService();
		try {
			broker.setPersistent(false);
			broker.setUseJmx(false);
			broker.setBrokerName("localhost");
			broker.addConnector("tcp://localhost:8182");
			broker.start();
			HelloWorldConsumer consumer = new HelloWorldConsumer();
			thread(consumer, false);
		} catch (Exception e) {
			e.printStackTrace();
		}

	}

	public static void thread(Runnable runnable, boolean daemon) {
		Thread brokerThread = new Thread(runnable);
		brokerThread.setDaemon(daemon);
		brokerThread.start();
	}

}