Thanks, when I modify the policy to
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry queue=">"
producerFlowControl="false" />
</policyEntries>
</policyMap>
</destinationPolicy>
I get (after a while)
javax.jms.IllegalStateException: The Session is closed
at
org.apache.activemq.ActiveMQSession.checkClosed(ActiveMQSession.java:731)
at org.apache.activemq.ActiveMQSession.commit(ActiveMQSession.java:554)
at org.apache.activemq.pool.PooledSession.commit(PooledSession.java:163)
at com.peerius.jms.manager.Publisher.commit(Publisher.scala:51)
I do have a lot of disk bandwidth to store the messages, so this exception
comes as a surprise. I assume the messages are stored to kahadb ( and I can
see it using more disk space ), so it wouldn't be a problem. I want to
continouusly produce messages even without a consumer and I am ok for them
to be stored in disk.
I've looked around and tried a couple of configs without any luck so far. Is
there a config where activemq will store the messages to disk without
minding about this?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/activemq-deadlocks-when-publisher-tries-to-commit-tp4671888p4671910.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
