я заметил, с ActiveMQ (5.5), если я делаю это псевдокод:activemq потребитель кажется «всегда кеш»?
connection = new ActiveMQConnectionFactory(...)
connection.start()
session = connection.createSession(transacted=true, Session.AUTO_ACKNOWLEDGE)
destination = session.createQueue(...)
consumer = session.createConsumer(destination)
что потребитель появляется, чтобы захватить элемент из очереди, прежде чем я даже запросить. Даже если я делаю wireFormat.cacheEnabled = false
Кто-нибудь знает, как предотвратить поступление потребителя из «захвата элемента» по умолчанию?
Что ваша строка соединения выглядит? это приведет к предварительной выборке. –
? WireFormat.maxInactivityDuration = 0 & wireFormat.cacheEnabled = false – rogerdpack
Попробуйте добавить '& jms.prefetchPolicy.all = 0' и посмотреть, не остановится ли это. Имейте в виду, что эта предварительная выборка не является необходимой потребностью: http://activemq.apache.org/what-is-the-prefetch-limit-for.html –