모질이의 ph0ebus.net

URL url = new URL("http://{ENGINE_SERVER_IP}/context/engine");
URLConnection connection = url.openConnection();
connection.addRequestProperty("tid", (String)params.get("tid"));
// Timestamp, Session ID 등으로 Unique한 ID값을 생성하여 리턴 - 결과 핸들러의 filter key가 됨
(.. 필요한 파라미터를 더 추가하던지 어쩌던지 ..)

String tid = request.getParameter("tid");
if (tid != null) {
    Long ts = new Date().getTime();
    AsyncMessage msg = new AsyncMessage();
    msg.setDestination(DESTINATION_ID);
    msg.setClientId(tid);
    msg.setMessageId("msg" + ts);
    msg.setTimestamp(ts);
    msg.setHeader(AsyncMessage.SUBTOPIC_HEADER_NAME, tid);
    HashMap map = new HashMap();
    Enumeration params = request.getParameterNames();
    while(params.hasMoreElements()) {
        String pName = (String)params.nextElement();
        String pValue = request.getParameter(pName);
        map.put(pName, pValue);
    }
    msg.setBody(map);
    MessageBroker.getMessageBroker(null).routeMessageToService(msg, null);
}

public function PhAsyncRemoteProcedure(producerDestination:String, consumerDestination:String) {
    super();
    consumer = new Consumer();
    consumer.destination = consumerDestination;
    consumer.addEventListener(MessageFaultEvent.FAULT, faultHandler);
    consumer.addEventListener(MessageEvent.MESSAGE, messageHandler);
    producer = new RemoteObject(producerDestination)
    producer.addEventListener("result", produceResultHandler);
}

private var producer:PhRemoteObject;
private var consumer:Consumer;

// 최초 json 호출
public function call(parameters:Object):void {
    producer.call(parameters);
}

// 생성된 tid로 Consumer 설정
private function produceResultHandler(event:ResultEvent):void {
    var ev:SomeEvent = new SomeEvent("call");
    ev.result = event.result;
    dispatchEvent(ev);
    consumer.subscribe(String(event.result.tid));
}

// 최종 결과값이 발생했을 때 처리
private function messageHandler(event:MessageEvent):void {
    var ev:SomeEvent = new SomeEvent("result");
    ev.result = event.message.body;
    dispatchEvent(ev);
}