注意这行很关键

<property name="brokerURL" value="failover://(tcp://127.0.0.1:61616)?initialReconnectDelay=100" /> 

是为了保证断线自动重连；如果没有设置，程序与ActiveMQ服务连接后期间出现过网络异常，再程序无法与ActiveMQ正常通讯；

3、测试程序

发送消息程序：

public class MessageSender{
	
	protected Logger log = Logger.getLogger(MessageReceiver.class.getName());
	
	private static JmsTemplate jmsTemplate = (JmsTemplate)MyApplicationContextUtil.context.getBean("jmsTemplate");
	private static Destination vehAlarmTopic = (Destination)MyApplicationContextUtil.context.getBean("vehAlarmTopic");
	private static Destination vehPassTopic = (Destination)MyApplicationContextUtil.context.getBean("vehPassTopic");
	static MyMessageCreator mc = null;
	/* 
	 * 
	 */
	public static boolean sendLiveMessage(Object msg){
		boolean isSend = false;
		mc = new MyMessageCreator(msg);
		jmsTemplate.send(vehPassTopic, mc);
		isSend = true;
		
		return isSend;
	}
	
	public static boolean sendBKMessage(Object msg){
		boolean isSend = false;
		MyMessageCreator mc = new MyMessageCreator(msg);
		jmsTemplate.send(vehAlarmTopic, mc);
		isSend = true;
		
		return isSend;
	}
	
	public static void main(String args[]) throws Exception {
		ApplicationContext context = new ClassPathXmlApplicationContext(
                new String[] { "applicationContext-mq.xml" });
        JmsTemplate jmsTemplate = (JmsTemplate) context.getBean("jmsTemplate");
        Destination destinationTopic = (Destination) context.getBean("destinationTopic");
        for (int i = 1; i < 10; i++) {
            MyMessageCreator mc = new MyMessageCreator("test");//生成消息
            jmsTemplate.send(destinationTopic, mc);
            Thread.sleep(1000);//1秒后发送下一条消息
        }

    }
}

public class MessageReceiver {
	
	protected Logger log = Logger.getLogger(MessageReceiver.class.getName());
	
	private static JmsTemplate jmsTemplate = (JmsTemplate)MyApplicationContextUtil.context.getBean("jmsTemplate");
	private static Destination vehPassTopic = (Destination)MyApplicationContextUtil.context.getBean("vehPassTopic");
	
	/**
	 * 
	 * @return
	 */
	public static List<Message> receiveMessage(){
		List<Message> msgList = null;
		Message message = null;
        
        for (int i = 0; i < 100;) {//每次接收100条记录
    		message = jmsTemplate.receive(vehPassTopic);
    		if(message != null){
    			msgList.add(message);
    			/*if (message instanceof TextMessage) {
    				 i++;
    				 msg = (TextMessage)message;
    				 returnMsg =  msg.getText();
    		         log.debug("收到消息 :" + msg.getText());
    			}*/
    		}else{
    			break;
    		}
        }
		return msgList;
	}
	
	
	public static void main(String args[]) throws Exception {
		ApplicationContext context = new ClassPathXmlApplicationContext(
                new String[] { "applicationContext-mq.xml" });
        JmsTemplate jmsTemplate = (JmsTemplate) context.getBean("jmsTemplate");
        Destination destinationTopic = (Destination) context.getBean("destinationTopic");
        TextMessage msg = null;
        for (int i = 0; i < 10; i ++) {
            msg = (TextMessage) jmsTemplate.receive(destinationTopic);
            System.out.println("收到消息 :" + msg.getText());
            Thread.sleep(1000);
        }
    }
	
}

管理界面如下：访问地址：http://127.0.0.1:8161/admin/