Timothy Bish (Confluence) Tue, 24 Mar 2015 06:23:19 -0700
...
Option Name
Default Value
Description
consumer.prefetchSize
variable
The number of message the consumer will prefetch. Removed in NMS.ActiveMQ v1.7.0 use the PrefetchPolicy isntead.
consumer.maximumPendingMessageLimit
0
Use to control if messages for non-durable topics are dropped if a slow consumer situation exists.
consumer.noLocal
false
Same as the noLocal flag on a Topic consumer. Exposed here so that it can be used with a queue.
consumer.dispatchAsync
true
Should the broker dispatch messages asynchronously to the consumer.
consumer.retroactive
Is this a Retroactive Consumer.
consumer.selector
null
NMS Selector used with the consumer.
consumer.exclusive
Is this an Exclusive Consumer.
consumer.priority
Allows you to configure a Consumer Priority.
var queue = session.GetQueue("TEST.QUEUE?consumer.dispatchAsync=false&consumer.prefetchSize=10"); var consumer = session.CreateConsumer(queue);