-Djeus.jms.client.use-single-server-entry=false

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

다음은 WebAdmin의 MQ로부터 WebLogic 10.3의 MQ로의 Bridge를 설정한 예제 화면이다.

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

Message Connections 영역에 MQ와 WebLogic 10.3의 MQ에 대한 설정을 하고, Message Entries에 이 둘 사이의 연결을 설정한다.

Message Connection이나 Message Entry의 세부 항목을 설정하려면 설정하려는 항목의 이름을 클릭한다. 다음과 같이 세부 항목 설정화면으로 이동하면 각 항목의 정보를 설정하고 [확인] 버튼을 클릭하면 설정한 정보가 저장된다. 항목을 다시 설정하려면 [재설정] 버튼을 클릭한다.

각 세부 항목 설정화면은 다음과 같다.

서버의 Message Sort 설정은 WebAdmin의 [Server] > [서버 선택] > [Engine] > [Jms Engine] > [Message Sort] 메뉴를 선택한다.

Message Sort 기능을 사용하려면 서버에 다음과 같이 기준을 설정해야 한다.

이후에 다음과 같이 Destinaition이나 Durable Subscriber에서 위의 기준으로 만들어진 Message Sort 기능을 사용하도록 설정할 수 있다. 자세한 내용은 “3.2.1. Destination 설정”과 “3.2.2. Durable Subscriber 설정”을 참조한다.

지정한 키값에 해당하지 않는 메시지들은 정렬의 대상이 되지 않는다. 이 경우에는 최대한 원래의 순서가 보장된다. 즉, 키값에 해당하는 메시지와 그렇지 않은 메시지들이 혼합되어서 큐에 쌓일 경우 키값에 해당하는 메시지들은 설정에 따라 정렬이 되고 그렇지 않은 메시지들은 메시지들 간의 원래의 순서가 보장된다.

클라이언트에서는 대상이 될 메시지에 정렬의 기준이 될 키값을 프로퍼티로 설정한다.

서버의 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를 구별해주는 이름은 여러 클라이언트에 걸쳐서 공유하여 사용할 수 있다.

Message Group 기능을 사용하기 위해 필요한 서버 설정들에 대해서 설명한다. Message Group은 Destination 설정화면에서 추가로 설정한다. Destination 설정화면에 대한 자세한 내용은 “3.2.1. Destination 설정”을 참고한다.

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

Queue 또는 Durable subscriber 내에 들어온 메시지를 모니터링할 수 있다.

메시지 목록 조회

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

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

메시지 상세 정보 조회

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

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

서버에 들어온 메시지들에 대해 다음과 같은 제어 기능을 제공한다.

메시지 이동

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

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

메시지 삭제

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

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

메시지 내보내기

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

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

메시지 가져오기

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

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

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

Destination의 생산 일시중지 및 재개

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

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

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

Destination의 소비 일시중지 및 재개

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

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

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

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