Waitinga在Play with rabbitMQ的消息

Question

我正在使用rabbitMQ模塊發送和接收消息。

有沒有人知道如何發送消息，然後再繼續等待另一條消息。

我需要做這樣的事情

public static void index(){ 

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

    render(message2); 

} 

Answer 1

我不知道RabbitMQ的API，但你不能把它當作異步IO？嘗試閱讀Play的承諾對象official docs。

喜歡的東西可能：

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

顯然，關鍵是你如何包裹在無極的RabbitMQ的電話。