Модераторы: LSD, AntonSaburov
  

Поиск:

Ответ в темуСоздание новой темы Создание опроса
> Как отложить обработку сообщения в ActiveMQ 
:(
    Опции темы
startpoint
Дата 31.1.2013, 16:22 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Новичок



Профиль
Группа: Участник
Сообщений: 47
Регистрация: 4.7.2007

Репутация: нет
Всего: нет



Есть ActiveMQ. Есть листенер, у которого есть метод
Код

public void onMessage(Message message) {
}

И вот например прилетает первая месага. Я её успешно обрабатываю. Вторую тоже. А вот третью, я не хочу обрабатывать, пока не выполнится первая. Первая может обрабатываться несколько часов в отдельном потоке. И вот я бы хотел сказать ActiveMQ, что не готов обработать сейчас эту третью месагу (а четвёртую могу и обработать, например), напомни мне о ней через минуту (фактически каждую минуту, в течении тех нескольких часов, пока работает поток, обрабатывающий первое сообщение). Можно ли так сделать? Т.е. использовать ActiveMQ как пул из которого можно захотеть что и не брать, пока не захочется...
Как вариант я подумал, что можно в таком случае отсылать это же сообщение самому себе с задержкой http://activemq.apache.org/delay-and-sched...e-delivery.html
Но может есть какое то концептуально правильное решение, а не такой хак?
PM MAIL   Вверх
mbasil
Дата 2.2.2013, 08:34 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Опытный
**


Профиль
Группа: Участник
Сообщений: 399
Регистрация: 4.5.2007
Где: Москва

Репутация: 2
Всего: 13



PM MAIL   Вверх
startpoint
Дата 4.2.2013, 12:51 (ссылка) | (нет голосов) Загрузка ... Загрузка ... Быстрая цитата Цитата


Новичок



Профиль
Группа: Участник
Сообщений: 47
Регистрация: 4.7.2007

Репутация: нет
Всего: нет



в упор не вижу. Можно поподробнее?
PM MAIL   Вверх
  
Ответ в темуСоздание новой темы Создание опроса
Правила форума "Java"
LSD   AntonSaburov
powerOn   tux
javastic
  • Прежде, чем задать вопрос, прочтите это!
  • Книги по Java собираются здесь.
  • Документация и ресурсы по Java находятся здесь.
  • Используйте теги [code=java][/code] для подсветки кода. Используйтe чекбокс "транслит", если у Вас нет русских шрифтов.
  • Помечайте свой вопрос как решённый, если на него получен ответ. Ссылка "Пометить как решённый" находится над первым постом.
  • Действия модераторов можно обсудить здесь.
  • FAQ раздела лежит здесь.

Если Вам помогли, и атмосфера форума Вам понравилась, то заходите к нам чаще! С уважением, LSD, AntonSaburov, powerOn, tux, javastic.

 
0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема | Java: Общие вопросы | Следующая тема »


 




[ Время генерации скрипта: 0.0585 ]   [ Использовано запросов: 22 ]   [ GZIP включён ]


Реклама на сайте     Информационное спонсорство

 
По вопросам размещения рекламы пишите на vladimir(sobaka)vingrad.ru
Отказ от ответственности     Powered by Invision Power Board(R) 1.3 © 2003  IPS, Inc.