[java] ActiveMQ와 감시 목적지 설정

28 Nov 2023

java

ActiveMQ는 오픈 소스 메시지 브로커로, 메시지 큐의 전송과 수신을 지원합니다. 이 문서에서는 ActiveMQ를 사용하여 감시 목적지를 설정하는 방법에 대해 알아보겠습니다.

1. 감시 목적지

감시 목적지는 ActiveMQ에서 메시지를 전송할 때 정의된 대상입니다. 이는 메시지 큐나 토픽과 같은 ActiveMQ의 목적지로 설정될 수 있습니다.

2. ActiveMQ 감시 목적지 설정

ActiveMQ에서 감시 목적지를 설정하기 위해서는 다음 단계를 따르면 됩니다.

2.1. ActiveMQ 연결 설정

ActiveMQ에 연결하기 위해 다음과 같이 Java 코드에서 ConnectionFactory를 생성하고 연결합니다.

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import org.apache.activemq.ActiveMQConnectionFactory;

ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://localhost:61616");
Connection connection = connectionFactory.createConnection();
connection.start();

2.2. 감시 목적지 생성

감시 목적지를 생성하기 위해 다음과 같이 Java 코드에서 Destination을 생성합니다.

import javax.jms.Destination;
import org.apache.activemq.command.ActiveMQQueue;

Destination destination = new ActiveMQQueue("watchlist.queue");

2.3. 감시 목적지 설정

감시 목적지 설정을 위해 다음과 같이 Java 코드에서 Producer를 생성하고 목적지를 설정합니다.

import javax.jms.MessageProducer;
import javax.jms.Session;
import org.apache.activemq.Message;

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageProducer producer = session.createProducer(destination);

2.4. 감시 목적지에 메시지 전송

감시 목적지에 메시지를 전송하기 위해 다음과 같이 Java 코드에서 Message를 생성하고 전송합니다.

Message message = session.createTextMessage("Hello, World!");
producer.send(message);