Springboot統合activemq

Springboot統合activemqは非常に簡単です.
まずspring-boot-starter-activemqに依存する.

      
      org.springframework.boot
      spring-boot-starter-activemq
    

次に、プロファイルにactivemqに関するパラメータを設定します.

spring.activemq.broker-url=tcp://192.168.1.210:9876
spring.activemq.user=admin
spring.activemq.password=secret

これで構成はほぼ完了しました.
生産者と消費者コードです

@Component
public class MyProducer {

	private final JmsTemplate jmsTemplate;
	
	@Autowired
	public MyProducer(JmsTemplate jmsTemplate) {
		this.jmsTemplate = jmsTemplate;
	}
	
	public void sendMessage(String destinationName, final String message) {    
        jmsTemplate.send(destinationName, new MessageCreator() {   
			public Message createMessage(Session session) throws JMSException {
				return session.createTextMessage(message); 
			}   
        });
    }
}

@Component
public class MyConsumer {

	@JmsListener(destination = "myQueue")
	public void processMessage(String content) {
		System.out.println("mq receive====================>"+content);
	}
}

終わりました.
転載は出典を明記してください.http://blog.csdn.net/redstarofsleep