하나의 Message Bridge를 사용하려면 2가지 설정이 필요하다.

Message Bridge는 JEUS의 MQ와는 별도로 동작하기 때문에 해당 설정은 WebAdmin 왼쪽 메뉴에 [리소스] > [Message Bridge]를 선택한다.

Message Connections 영역에 MQ와 타 벤더의 MQ에 대해 각각 설정을 하고, Message Entries에 이 둘 사이의 연결을 설정한다. Message Connection이나 Message Entry의 세부 항목을 설정하려면 설정하려는 항목의 이름을 클릭하여 설정한다.

Connection의 Classpath는 다음의 예제와 같이 줄바꿈으로 구분되어 나열되도록 설정해야 한다.

lib/client/clientcontainer.jar
lib/system/jms.jar
. . .

클라이언트에서는 대상이 될 메시지에 정렬의 기준이 될 키값을 프로퍼티로 설정한다. 서버의 Message Sort 설정에서 Message Sort 키를 "TEST_KEY"로 설정했다는 가정을 하고 다음의 예제와 같이 설정하면 메시지들이 정렬된다.

Message msg = session.createTextMessage("Test");
msg.setIntProperty("TEST_KEY", 1);     

Global Order 기능은 서버에 별다른 설정 없이 클라이언트에서 전용 API를 호출하여 사용할 수 있다.

메시지 송신자에서 Producer를 생성한 후 JeusMessageProducer로 casting하여 전용 API를 호출한다.

JeusMessageProducer producer = (JeusMessageProducer) session.createProducer(queue);
// Global Order 지정 및 이름 할당
producer.startGlobalOrder("GLOBAL-ORDER-NAME");
// 이름을 지정하지 않는 경우
//producer.startGlobalOrder();

GLOBAL-ORDER-NAME은 각 Global Order를 구별해주는 이름으로 할당하지 않는 경우 임의의 이름이 할당된다. 이후 메시지 송신은 기존과 같다. Global Order를 구별해주는 이름은 여러 클라이언트에 걸쳐서 공유하여 사용할 수 있다. 이 기능을 클러스터링과 함께 사용하면 클러스터 전체에 대해서 처리 순서를 최대한 보장한다.

클라이언트 설정은 메시지 송신자와 메시지 수신자 각각의 정보를 설정해야 한다.

Queue 또는 Durable subscription 내에 들어온 메시지를 모니터링하고 각 메시지 정보를 조회한다.

Queue 또는 Durable subscription 내에 남아있는 모든 메시지들의 목록을 조회하는 기능이다. 각 메시지들의 ID, 타입, 생성 시각 등의 간단한 정보를 조회하고, 조회된 목록에서 메시지를 선택해서 상세 정보 조회, 삭제, 이동, 내보내기 등의 다른 기능을 수행할 수 있다.

메시지 목록 조회 과정은 다음과 같다.

메시지 상세 정보 조회는 Queue 또는 Durable subscription으로 들어온 메시지의 상세 정보를 조회하는 기능이다. JMS 스펙에서 지정하는 헤더들의 모든 내용을 확인할 수 있으며 메시지의 정보와 설정된 속성들을 확인할 수있다.

메시지 상세 정보 조회 방법은 다음과 같다.

WebAdmin의 [상태] > [JMS] 메뉴를 선택하고 [Destinations] 탭의 [Server]를 선택하면 Destination 화면으로 이동한다. 해당 화면에서 서버에 들어온 메시지들에 대해 이동, 삭제, 내보내기, 가져오기와 같은 제어 기능을 제공한다.

서버 또는 클러스터 내의 다른 Destination으로 메시지를 이동시킬 수 있다. 잘못된 Destination으로 메시지를 보내는 등의 실수 상황에 대처할 수 있는 유용한 기능이다.

메시지 이동 과정은 다음과 같다.

메시지 삭제는 서버 내의 메시지가 더 이상 필요하지 않게 된 경우에 사용하는 기능이다.

메시지 삭제 과정은 다음과 같다.

Queue 또는 Durable subscriber 내의 메시지를 다른 서버나 클러스터로 옮길 수 있는 형태로 내보내는 기능이다.

메시지 내보내기 과정은 다음과 같다.

메시지 내보내기 기능을 수행하면 생성되는 XML 파일을 이용해서 서버 내의 특정 Destination으로 메시지를 가져올 수 있다. 메시지 이동과는 달리 전혀 새로운 메시지로 취급되며, 메시지가 Destination으로 들어오는 순간 새로운 Message ID가 발급된다.

메시지 가져오기 과정은 다음과 같다.

서버 내의 Destination별로 생산 및 소비 서비스를 일시중지하거나 재개할 수 있다.

해당 Destination으로 메시지를 생산하는 것을 일시중지하거나 재개하는 기능이다. Destination이 생산 일시중지 상태가 되면 해당 Destination으로 메시지를 생산하는 것이 불가능해진다.

WebAdmin의 [상태] > [JMS] 메뉴를 선택하고 [Destinations] 탭의 [Server]를 선택한다. 해당 서버의 Destination 목록이 조회된다.

각 Destination별로 'Produce suspended' 값을 통해 메시지 생산에 대한 Destination의 현재 상태를 확인할 수 있고 각 버튼을 클릭해서 Destination의 상태를 변경할 수 있다.

해당 Destination에서 메시지 소비를 일시중지하거나 재개하는 기능이다. Destination의 소비가 일시중지 상태가 되면 해당 Destination에서 메시지를 소비하는 것이 불가능해진다.

WebAdmin의 [상태] > [JMS] 메뉴를 선택하고 [Destinations] 탭의 [Server]를 선택한다. 해당 서버의 Destination 목록이 조회된다.

각 Destination별로 'Consume suspended' 값을 통해 메시지 소비에 대한 Destination의 현재 상태를 확인할 수 있고 각 버튼을 클릭해서 Destination의 상태를 변경할 수 있다.

IP Mulitcast를 통해 Topic 메시지를 주고받기 위해서는 두 가지 설정이 필요하다. 먼저 서버와 클라이언트가 같은 Multicast 주소로 연결하도록 설정해야 하며, 서버에 연결된 클라이언트가 메시지를 받는 방식을 Topic Multicast로 지정하도록 설정해야 한다.

Multicast 주소는 Destination 설정에 설정하도록 되어 있다. Topic인 Destination 설정에 Multicast 주소를 포함시켜 해당 Destination을 사용하는 클라이언트에서 별도의 클라이언트 설정 없이 서버와 동일한 Multicast 주소를 통해 메시지를 받을 수 있게 되어 있다.

클라이언트가 메시지를 받는 방식을 Topic Multicast로 지정하는 설정은 ConnectionFactory에 설정하고 있다. Topic Multicast 기능을 사용하려면 Topic Multicast가 설정된 ConnectionFactory를 사용한다. 메시지를 받아오려면 Destination에 Topic Multicast 설정이 되어 있지 않다면 TCP 방식(기존 방식)으로 메시지를 받아오게 된다. 마찬가지로 Topic Multicast가 설정된 Destination에서 메시지를 받아오더라도 ConnectionFactory에 Topic Multicast 설정이 되어있지 않다면, TCP 방식으로 메시지를 받아온다. Durable subscription을 사용하는 경우 일반 Topic 메시지보다 높은 수준의 신뢰도를 요구하며, 1개의 Subscription이 동시에 1개의 클라이언트에만 메시지를 전달하기 때문에 Topic Multicast 기능을 지원하지 않는다.

LPQ를 활용하여 신뢰도 높은 메시지 송신 기능을 사용하려면 먼저 LPQ를 활성화시켜야 한다. LPQ를 활성화시키는 과정은 메시지들을 저장할 저장소 생성, 메시지 처리를 위한 큐와 그리고 이들을 관리하기 위한 관리 객체 생성으로 이뤄져 있다.

LPQ를 활성화시키는 방법은 크게 3가지로 나뉜다.

LPQ가 활성화 되었다면 메시지를 보낼 때 이를 LPQ를 통해 전송되도록 하여 메시지 송신의 신뢰도를 높일 수 있다. 이때 메시지가 LPQ를 통해 전송되도록 설정하는 단위는 다음과 같이 네가지로 나눌 수 있다.

메시지 전송에 LPQ를 사용하면 메시지가 비동기적으로 처리되어 실제 메시지가 전송되는 것을 클라이언트에서 알 수 없다. 때문에 메시지 전송의 결과와 정확한 시점을 알 수 있도록 LPQ에서는 리스너를 제공하고 있다.

리스너를 통해 메시지 전송의 결과를 받기 위해 interface로 제공되는 리스너인 jeus.jms.LPQMessageListener는 다음과 같다.

package jeus.jms;

public interface LPQForwardListener {
    /**
     * 메시지의 전송이 완료되었을 때 이벤트
     * @param message 전송된 메시지
     */
    public void onComplete(Message message);

    /**
     * 메시지의 전송 도중 Exception이 발생했을 때 이벤트
     * @param message 전송하려던 메시지
     * @param e 발생한 Exception
     */
    public void onException(Message message, Exception e);

    /**
     * 메시지의 전송이 실패하였을 때 이벤트
     *
     * @param message 전송이 실패한 메시지
     * @param cause 전송이 실패한 원인
     */
    public void onFailure(Message message, Throwable cause);
}

구현된 LPQMessageListener를 JMS 세션의 JEUS 전용 객체인 JeusSession에 다음 API를 사용하여 등록하면 메시지 전송의 결과를 제공받을 수 있다.

public void setLPQMessageListener(jeus.jms.LPQMessageListener lpqMessageListener);

또한 JEUS 전용 객체를 사용하여 LPQ를 활성화하는 경우 JeusSession의 다음 API를 사용하여 LPQ 활성화와 리스너 등록을 동시에 할 수도 있다.

public void startLPQ(jeus.jms.LPQMessageListener lpqMessageListener);

LPQ는 실패한 전송에 대한 처리, 연결이 끊어졌을 때의 동작, 저장소의 위치 또는 크기에 대한 설정들이 필요하다.

다음은 LPQ 설정 항목에 대한 설명이다.