Waitinga для сообщения в Play with rabbitMQ - PullRequest
0 голосов
/ 27 марта 2012

Я использую модуль rabbitMQ для отправки и получения сообщений.

Кто-нибудь знает, как я могу отправить сообщение и чем ждать другого сообщения, прежде чем продолжить.

Мне нужно сделать что-то вродеэто

public static void index(){

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

    render(message2);

}

1 Ответ

0 голосов
/ 28 марта 2012

Я не знаю API RabbitMQ, но разве вы не можете рассматривать это как асинхронный ввод-вывод? Попробуйте прочитать об обещании Play объект официальные документы .

Что-то вроде может быть:

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

Очевидно, что ключ будет заключаться в том, как завершить вызов RabbitMQ в Обещании.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...