2012-03-26 7 views
0

私はrabbitMQモジュールを使ってメッセージを送受信しています。rabbitMQでPlayのメッセージを待っています

どのようにメッセージを送信し、続行する前に別のメッセージを待つことができるか知っていますか?

私はRabbitMQのAPIを知らないが、あなたはIO非同期としてこれを扱うことができないこの

public static void index(){ 

    RabbitMQPublisher.publish("queue1", message1); 
    .... 
    //here i need to wait for message to arrive on queue2 

    render(message2); 

} 

答えて

0

ような何かをする必要がありますか? PlayのPromiseオブジェクトofficial docsを読んでみてください。多分などの

何か:

Promise<String> delayedResult = veryLongComputation(…); 
String result = await(delayedResult); 
render(result); 

明らかキーはあなたが約束してRabbitMQの呼び出しをラップする方法になります。

関連する問題