Re: how to set pendingSubscriberPolicy for an embedded broker

2011-05-19 Thread Marcelo Jabali
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

Re: how to set pendingSubscriberPolicy for an embedded broker

2011-05-19 Thread Steve Angelovich
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

Re: how to set pendingSubscriberPolicy for an embedded broker

2011-05-19 Thread Marcelo Jabali
Steve, I believe you're looking for something similar to this: PolicyEntry policy = new PolicyEntry(); policy.setProducerFlowControl(true); policy.setMemoryLimit(50); policy.setDestination(topic);