21.4. 런타임 제어

21.4.1. 개요

런타임 시 WS-RM을 제어하기 위해 클라이언트 코드에서 여러 메시지 컨텍스트 속성 값을 설정할 수 있으며, org.apache.cxf.ws.rm.RMManager 클래스에 공용 상수로 정의된 키 값을 사용할 수 있습니다.

21.4.2. 런타임 제어 옵션

다음 표에는 org.apache.cxf.ws.rm.RMManager 클래스에서 정의된 키가 나열되어 있습니다.

키설명

WSRM_VERSION_PROPERTY

string WS-RM 버전 네임스페이스(http://schemas.xmlsoap.org/ws/2005/02/rm/ 또는 http://docs.oasis-open.org/ws-rx/wsrm/200702).

WSRM_WSA_VERSION_PROPERTY

문자열 WS-Addressing 버전 네임스페이스(http://schemas.xmlsoap.org/ws/2004/08/addressing 또는 http://www.w3.org/2005/08/addressing) - http://schemas.xmlsoap.org/ws/2005/02/rm/ RM 네임스페이스를 사용하지 않는 한 이 속성은 무시됩니다.

WSRM_LAST_MESSAGE_PROPERTY

WS-RM 코드에서 마지막 메시지가 전송되고 있음을 나타내기 위해 true 로 설정하면 코드가 WS-RM 시퀀스 및 릴리스 리소스를 종료할 수 있습니다(CXF의 3.0.0 버전인 경우 WS-RM은 클라이언트를 닫을 때 기본적으로 RM 시퀀스를 종료합니다.)

WSRM_INACTIVITY_TIMEOUT_PROPERTY

비활성 기간(밀리초)입니다.

WSRM_RETRANSMISSION_INTERVAL_PROPERTY

긴 기본 재전송 간격(밀리초)입니다.

WSRM_EXPONENTIAL_BACKOFF_PROPERTY

부울 지수 백오프 플래그입니다.

WSRM_ACKNOWLEDGEMENT_INTERVAL_PROPERTY

장기 승인 간격(밀리초)입니다.

21.4.3. JMX를 통한 WS-RM 제어

Apache CXF의 JMX 관리 기능을 사용하여 WS-RM의 여러 측면을 모니터링하고 제어할 수도 있습니다. JMX 작업의 전체 목록은 org.apache.cxf.ws.ManagedRMManager 및 org. apache.cxf.ws.rm.ManagedRMEndpoint 에 의해 정의되지만 이러한 작업에는 현재 RM 상태를 개별 메시지 수준으로 보는 작업이 포함됩니다. JXM을 사용하여 WS-RM 시퀀스를 종료하거나 종료하고 이전에 전송된 메시지가 원격 RM 끝점에 의해 승인될 때 알림을 받을 수도 있습니다.

21.4.4. JMX 제어의 예

예를 들어 클라이언트 구성에 JMX 서버가 활성화된 경우 다음 코드를 사용하여 수신된 마지막 승인 번호를 추적할 수 있습니다. 

// Java
private static class AcknowledgementListener implements NotificationListener {
    private volatile long lastAcknowledgement;

    @Override
    public void handleNotification(Notification notification, Object handback) {
        if (notification instanceof AcknowledgementNotification) {
            AcknowledgementNotification ack = (AcknowledgementNotification)notification;
            lastAcknowledgement = ack.getMessageNumber();
        }
    }

    // initialize client
...
    // attach to JMX bean for notifications
    //  NOTE: you must have sent at least one message to initialize RM before executing this code
    Endpoint ep = ClientProxy.getClient(client).getEndpoint();
    InstrumentationManager im = bus.getExtension(InstrumentationManager.class);
    MBeanServer mbs = im.getMBeanServer();
    RMManager clientManager = bus.getExtension(RMManager.class);
    ObjectName name = RMUtils.getManagedObjectName(clientManager, ep);
    System.out.println("Looking for endpoint name " + name);
    AcknowledgementListener listener = new AcknowledgementListener();
    mbs.addNotificationListener(name, listener, null, null);

    // send messages using RM with acknowledgement status reported to listener
...