public?class?AppProducer?{

	private?static?final?String?url="tcp://127.0.0.1:61616";
	private?static?final?String?queueName="queue-test";
	
	public?static?void?main(String[]?args)?throws?JMSException?{
		
		//1.創建ConnectionFactory連接工廠
		ConnectionFactory?connectionFactory=new?ActiveMQConnectionFactory(url);
		
		//2.創建連接
		Connection?connection?=connectionFactory.createConnection();
		
		//3.啟動連接
		connection.start();
		
		//4.創建會話
		Session?session=connection.createSession(false,?Session.AUTO_ACKNOWLEDGE);
		
		//5.創建目標
		Destination?destination=?session.createQueue(queueName);
		
		//6.創建生產者
		MessageProducer?messageProducer=?session.createProducer(destination);
		
		for(int?i=0;i<100;i++){
			//7.創建消息
			TextMessage?textMeasurer=session.createTextMessage("test:?"+i);
			
			//8.發布消息
			messageProducer.send(textMeasurer);
			
			System.out.println("發送消息:"+textMeasurer.getText());

		}
		
		//9.關閉連接
		connection.stop();
		
	}
}

public?class?AppConsumer?{
	
	private?static?final?String?url="tcp://127.0.0.1:61616";
	private?static?final?String?queueName="queue-test";
	
	public?static?void?main(String[]?args)?throws?JMSException?{
		
		//1.創建ConnectionFactory連接工廠
		ConnectionFactory?connectionFactory=new?ActiveMQConnectionFactory(url);
		
		//2.創建連接
		Connection?connection?=connectionFactory.createConnection();
		
		//3.啟動連接
		connection.start();
		
		//4.創建會話
		Session?session=connection.createSession(false,?Session.AUTO_ACKNOWLEDGE);
		
		//5.創建目標
		Destination?destination=?session.createQueue(queueName);
		
		//6.創建消費者
		MessageConsumer?messageConsumer?=?session.createConsumer(destination);
		
		//7.創建一個監聽器
		messageConsumer.setMessageListener(new?MessageListener()?{
			
			public?void?onMessage(Message?message)?{
				
				TextMessage?textMessage=?(TextMessage)?message;
				try?{
					System.out.println("接收消息:?"+textMessage.getText());
				}?catch?(JMSException?e)?{
					//?TODO?Auto-generated?catch?block
					e.printStackTrace();
				}
			}
		});
		
		
		//8.關閉連接
		//connection.stop();
		
	}
	
	
	
	
}

AppProducer可以生產發送到中間件

但是AppConsumer接收不到