Can you give this a try on a 5.12 SNAPSHOT? we fixed some issues with the cursor lists for queues... but there is still some slight issues in how the queue pages in messages when it's dispatch list is "full"... you can force it to page in more with a "browse".. but there's probably a better way to fix this. Though the fixes we did not long ago that are in 5.12-SNAPSHOT should help.
On Thu, Apr 16, 2015 at 3:39 PM, Jon Gorrono <jpgorr...@ucdavis.edu> wrote: > I am trying to do some testing an limit the output from a queue that has > about 4500 messages in it. Each message contains between 300 and 500 > documents attached that i process individually. But I am trying to test > only specific message types and not see the others so I restart the client > each cycle with different selector header values. I only have the one > client (stomp) running at any time (besides the admin web app)... all > connections are with ack: client-individual > > The problem I see is that the selector works fine if the 'top' of the queue > contains messages that match the selector, but I see nothing if the > selector matches messages deep in the queue. The client just waits forever > ... it seems to me that the server is waiting for acks but since the > selector hides the initial messages from the client, there's nothing for it > to ack. > > There are no producers active... I restore the kahadb each time I need to > replenish the queue > > I have DEBUG log4j settings for activemq packages but the logs only log > checkpoints and expiry scans > > > I would expect that the selector would cause the server to browser down the > queue for message it can dequeue. But does not appear to be happening > > > broker config: > <broker xmlns="http://activemq.apache.org/schema/core"; > brokerName="localhost" dataDirectory="${activemq.data}"> > > > <destinationPolicy> > <policyMap> > <policyEntries> > <policyEntry topic=">" producerFlowControl="true"> > > <pendingMessageLimitStrategy> > <constantPendingMessageLimitStrategy limit="1000"/> > </pendingMessageLimitStrategy> > </policyEntry> > <policyEntry queue=">" producerFlowControl="true" > memoryLimit="1mb"> > > </policyEntry> > </policyEntries> > </policyMap> > </destinationPolicy> > > > > <managementContext> > <managementContext createConnector="false"/> > </managementContext> > > > <persistenceAdapter> > <kahaDB directory="${activemq.data}/kahadb"/> > </persistenceAdapter> > > > > <systemUsage> > <systemUsage> > <memoryUsage> > <memoryUsage limit="64 mb"/> > </memoryUsage> > <storeUsage> > <storeUsage limit="100 gb"/> > </storeUsage> > <tempUsage> > <tempUsage limit="50 gb"/> > </tempUsage> > </systemUsage> > </systemUsage> > > > <transportConnectors> > > <transportConnector name="openwire" > > uri="tcp://host:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> > <transportConnector name="amqp" > > uri="amqp://host:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/> > <transportConnector name="stomp" uri="stomp://host:61613"/> > </transportConnectors> > > > <shutdownHooks> > <bean xmlns="http://www.springframework.org/schema/beans"; > class="org.apache.activemq.hooks.SpringContextHook" /> > </shutdownHooks> > > </broker> > > -- > Jon Gorrono > PGP Key: 0x5434509D - http{ > pgp.mit.edu:11371/pks/lookup?search=0x5434509D&op=index} > http{middleware.ucdavis.edu} > -- *Christian Posta* twitter: @christianposta http://www.christianposta.com/blog http://fabric8.io
