Jms + ActiveMQ

spring에서 msg를 전달하는 가장 흔한 방법은

JMS(+jmsTemplate)과 ActiveMQ(by apache)를 이용하는 방법이다. 물론 ASYNC 메시징이다.

ActiveMQ를 사용하고자 하면, ActiveMQConnectionFactory가 JMSConnectionFactory로써 제공된다.

 -디폴트 포트: 61616 

<Send>

ConnectionFactory cf =
      new ActiveMQConnectionFactory("tcp://localhost:61616";
Connection conn = cf.createConnection();

session = conn.createSession(..);

MessageProducer producer = session.createProducer(destination);

producer.send( session.createTextMessage('hello')..)

<Receive>

MessageConsumer consumer = session.createConsumer(destination);

Message message = consumer.receive();

<JmsTemplate을 사용하면 좀더 간단해진다>

jmsOperations.send(
  new MessageCreator() {
   ......blabla
  }

또는 컨버팅 필요시

 

jmsOperations.convertAndSend