ActiveMQ MUltiple подписки замораживает приложение - PullRequest
0 голосов
/ 02 марта 2011

У меня есть приложение, которое пытается подписаться на множество разных тем.

На стороне сервера публикуется много сообщений по этим темам, и как только приложение начинает подписку, оно получает так много сообщений, чтоприложение не может даже достичь конца функции подписки.

Кажется, что слушатель OnMessage так сильно загружен (слушатель - это класс, который пытается подписаться на все темы).

Так в принципе есть ли способ прекратить прием сообщений, пока я не подпишусь на все темы?Или я что-то там пропускаю?

Поток, пытающийся подписаться на все темы, никогда не получит процессор снова.(Если сервер не работает, с подпиской все в порядке, поскольку он ничего не получает, поэтому не теряет вычислительную мощность ..)

Заранее спасибо.

Пол.

1 Ответ

1 голос
/ 02 марта 2011

Вы можете попытаться снизить лимит предварительной выборки для потребителей, это помешает брокеру пытаться отправлять так много сообщений при их создании, что должно помочь уменьшить проблему с затоплением, которую вы видите.это может помочь.http://activemq.apache.org/what-is-the-prefetch-limit-for.html

Тим - www.fusesource.com

...