Hi Steve,
Take a look on org.apache.activemq.broker.region.policy.PolicyEntry
(http://activemq.apache.org/maven/5.3.1/activemq-core/apidocs/org/apache/activemq/broker/region/policy/PolicyEntry.html)
Hope this helps,
-Marcelo
On May 19, 2011, at 12:17 PM, Steve Angelovich wrote:
I have an
Thanks for the reference but I don't know all the classes well enough to
navigate through the javadocs and find the right information.
I have something like;
BrokerService broker = new BrokerService();
broker.setBrokerName(_host+_+_port);
broker.setUseJmx(true);
broker.setDataDirectory(new
Steve,
I believe you're looking for something similar to this:
PolicyEntry policy = new PolicyEntry();
policy.setProducerFlowControl(true);
policy.setMemoryLimit(50);
policy.setDestination(topic);