1 package com.thread;
 2 
 3 import com.activeMQ.ActiveMQHelper;
 4 import com.demo.testSpring.Animal;
 5 
 6 /**
 7  * 新创建线程，用于接受消息，并对应操作
 8  * @author czg
 9  *
10  */
11 public class worker extends Thread{
12     
13     public void run() {
14         String msg;
15         ActiveMQHelper activeMQHelper=new ActiveMQHelper("tcp://localhost:61616?wireFormat.maxInactivityDuration=0",2000);
16 
17         while(true){
18             msg=activeMQHelper.receiveMessage("hello");
19             if(!msg.equals("EOF")) System.out.println(msg);
20         
21         }
22     }
23 }

1 @Override
2     public void afterJFinalStart(){
3         
4         Thread workerThread = new Thread(new com.thread.worker());
5         workerThread.start();
6     }