blocking NMS C# consumer

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

blocking NMS C# consumer

gorbatov
I am using apache-activemq-5.10.0.
NMS lib is Apache.NMS.dll version 1.5.1 and Apache.NMS.ActiveMQ.dll version 1.5.6
Broker has eight queues. It uses kahaDB
Consumer works fine if there is no accumulation in queues.
After consumers stopped, messages accumulated and consumers  started with many msgs in the queue they are blocked and cannot read msgs.
Consumers run in separate threads. There are four independent threads - each thread corresponds to separate queue and consumer.
All queues are persitent and here is policy:
                </policyEntry>
                <policyEntry queue=">" producerFlowControl="false">
                </policyEntry>

here is usage
         <systemUsage>
            <systemUsage sendFailIfNoSpace="true"> 
                <memoryUsage>
                    <memoryUsage percentOfJvmHeap="70" />
                </memoryUsage>
                <storeUsage>
                    <storeUsage limit="30 gb"/>
                </storeUsage>
                <tempUsage>
                    <tempUsage limit="5 gb"/>
                </tempUsage>
            </systemUsage>
        </systemUsage>

free space on disk is 100GB right now.
Any ideas appreciated