You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by "magic.moose" <ma...@avedya.com> on 2007/01/25 16:15:42 UTC
Can't set prefetch size!
Hi.
AMQ4.1.0, Jencks, Spring 1.2.7.
Prefetch size for all queues is always 10. I tried to CHANGE it in many
places:
- in broker url (both in conf xml and embedded into connectionFactory).
- in activationSpec destination name.
- in xml config <queue> (name || physicalName ??).
It stays 10...
Broker is embedded, jvm. no persistance. Is there any other place? something
overides my settings? Its crazy. such a simple thing to do and takes ages...
BTW: I want to play with that setting to deal with very slow consumers. Im
loosing some messages (or rather they are stuck in the queue) when I bulk
send them.
M.M.
--
View this message in context: http://www.nabble.com/Can%27t-set-prefetch-size%21-tf3114996.html#a8628311
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Can't set prefetch size!
Posted by "Christopher G. Stach II" <cg...@ldsys.net>.
magic.moose wrote:
>
> jms.redeliveryPolicy.allPrefetchValues is not recognized as correct
> connection param in ver. 4.1.
> i tried jms.prefetchPolicy.all. Without success.
That's weird, because that's what I use and it works. :)
--
Christopher G. Stach II
Re: Can't set prefetch size!
Posted by "magic.moose" <ma...@avedya.com>.
jms.redeliveryPolicy.allPrefetchValues is not recognized as correct
connection param in ver. 4.1.
i tried jms.prefetchPolicy.all. Without success.
Christopher G. Stach II wrote:
>
> magic.moose wrote:
>>
>> I tried that. Resource Adapter simply references connectionFactory:
>> <bean id="broker"
>> class="org.apache.activemq.xbean.BrokerFactoryBean"
>> depends-on="serverConnector">
>> <property name="config"
>> value="classpath:broker.xml" />
>> <property name="start" value="true" />
>> </bean>
>> <bean id="connectionFactory"
>> class="org.apache.activemq.ActiveMQConnectionFactory"
>> singleton="true">
>> <property name="brokerURL" value="vm://localhost"/>
>> </bean>
>>
>> <bean id="jmsResourceAdapter"
>> class="org.apache.activemq.ra.ActiveMQResourceAdapter">
>> <property name="connectionFactory" ref="connectionFactory" />
>> </bean>
>>
>> where broker.xml:
>> <?xml version="1.0" encoding="UTF-8"?>
>>
>> <beans xmlns="http://activemq.org/config/1.0">
>>
>> <broker name="localhost" persistent="false" useJmx="true">
>>
>> <transportConnectors>
>> <transportConnector
>> uri="vm://localhost" />
>> </transportConnectors>
>> <memoryManager>
>> <usageManager id="memory-manager" limit="20 MB" />
>> </memoryManager>
>>
>> <destinationPolicy>
>> <policyMap><policyEntries>
>> <policyEntry queue="testQueue">
>> <dispatchPolicy>
>> <roundRobinDispatchPolicy/>
>> </dispatchPolicy>
>> <pendingMessageLimitStrategy>
>> <constantPendingMessageLimitStrategy limit="0"/>
>> </pendingMessageLimitStrategy>
>> </policyEntry>
>> </policyEntries></policyMap>
>> </destinationPolicy>
>>
>> </broker>
>>
>> </beans>
>>
>> queuePrefetch property of resource adapter doesnt help.
>> and it really is 10 !
>> it not only that it behaves like it is 10. thats what i can see via jmx.
>
> Try this:
>
> <bean id="connectionFactory"
> class="org.apache.activemq.ActiveMQConnectionFactory"
> singleton="true">
> <property name="brokerURL"
> value="vm://localhost?jms.redeliveryPolicy.allPrefetchValues=1"/>
> </bean>
>
>
> --
> Christopher G. Stach II
>
>
>
--
View this message in context: http://www.nabble.com/Can%27t-set-prefetch-size%21-tf3114996.html#a8767617
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Can't set prefetch size!
Posted by "Christopher G. Stach II" <cg...@ldsys.net>.
magic.moose wrote:
>
> I tried that. Resource Adapter simply references connectionFactory:
> <bean id="broker"
> class="org.apache.activemq.xbean.BrokerFactoryBean"
> depends-on="serverConnector">
> <property name="config"
> value="classpath:broker.xml" />
> <property name="start" value="true" />
> </bean>
> <bean id="connectionFactory"
> class="org.apache.activemq.ActiveMQConnectionFactory"
> singleton="true">
> <property name="brokerURL" value="vm://localhost"/>
> </bean>
>
> <bean id="jmsResourceAdapter"
> class="org.apache.activemq.ra.ActiveMQResourceAdapter">
> <property name="connectionFactory" ref="connectionFactory" />
> </bean>
>
> where broker.xml:
> <?xml version="1.0" encoding="UTF-8"?>
>
> <beans xmlns="http://activemq.org/config/1.0">
>
> <broker name="localhost" persistent="false" useJmx="true">
>
> <transportConnectors>
> <transportConnector
> uri="vm://localhost" />
> </transportConnectors>
> <memoryManager>
> <usageManager id="memory-manager" limit="20 MB" />
> </memoryManager>
>
> <destinationPolicy>
> <policyMap><policyEntries>
> <policyEntry queue="testQueue">
> <dispatchPolicy>
> <roundRobinDispatchPolicy/>
> </dispatchPolicy>
> <pendingMessageLimitStrategy>
> <constantPendingMessageLimitStrategy limit="0"/>
> </pendingMessageLimitStrategy>
> </policyEntry>
> </policyEntries></policyMap>
> </destinationPolicy>
>
> </broker>
>
> </beans>
>
> queuePrefetch property of resource adapter doesnt help.
> and it really is 10 !
> it not only that it behaves like it is 10. thats what i can see via jmx.
Try this:
<bean id="connectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory"
singleton="true">
<property name="brokerURL"
value="vm://localhost?jms.redeliveryPolicy.allPrefetchValues=1"/>
</bean>
--
Christopher G. Stach II
Re: Can't set prefetch size!
Posted by James Strachan <ja...@gmail.com>.
Incidentally in another thread someone spotted a bug that was
affecting the setting of custom consumer configurations in the RA, so
the latest 4.2-SNAPSHOT could help your issue
On 2/5/07, magic.moose <ma...@avedya.com> wrote:
>
> Yes, I just wanted to show config w/o prefetch stuff.
> Anyway, setting vm://localhost?jms.prefetchPolicy.all, or policies for
> queues, or for particular consumer via URL it all failed.
> So did setting of resource adapter properties according to
> http://activemq.apache.org/resource-adapter-properties.html.
> Weird thing is that 'default value' is 1000, well, at least in docs. Ive
> never ever seen 1000 while playing with 4.1 and jvm transport. Always 10.
>
> I havent tried to force it in code. I really dont want to go that way
> though.
>
> In fact there is no more config I use. Well activationSpec, maybe, for some
> consumer props. It works on default settings though...
>
> Maciek
>
>
> James.Strachan wrote:
> >
> > On 2/2/07, magic.moose <ma...@avedya.com> wrote:
> >>
> >>
> >> I tried that. Resource Adapter simply references connectionFactory:
> >
> > I'm confused - I don't see any attempt to set the prefetch policy in
> > your XML? If you are explicitly creating a connectionFactory and
> > passing it into the RA you could try configure that?
> >
> > James
> >
> >
> >> <bean id="broker"
> >> class="org.apache.activemq.xbean.BrokerFactoryBean"
> >> depends-on="serverConnector">
> >> <property name="config"
> >> value="classpath:broker.xml" />
> >> <property name="start" value="true" />
> >> </bean>
> >> <bean id="connectionFactory"
> >> class="org.apache.activemq.ActiveMQConnectionFactory"
> >> singleton="true">
> >> <property name="brokerURL" value="vm://localhost"/>
> >> </bean>
> >>
> >> <bean id="jmsResourceAdapter"
> >> class="org.apache.activemq.ra.ActiveMQResourceAdapter">
> >> <property name="connectionFactory"
> >> ref="connectionFactory" />
> >> </bean>
> >>
> >> where broker.xml:
> >> <?xml version="1.0" encoding="UTF-8"?>
> >>
> >> <beans xmlns="http://activemq.org/config/1.0">
> >>
> >> <broker name="localhost" persistent="false" useJmx="true">
> >>
> >> <transportConnectors>
> >> <transportConnector
> >> uri="vm://localhost" />
> >> </transportConnectors>
> >> <memoryManager>
> >> <usageManager id="memory-manager" limit="20 MB"
> >> />
> >> </memoryManager>
> >>
> >> <destinationPolicy>
> >> <policyMap><policyEntries>
> >> <policyEntry queue="testQueue">
> >> <dispatchPolicy>
> >> <roundRobinDispatchPolicy/>
> >> </dispatchPolicy>
> >> <pendingMessageLimitStrategy>
> >> <constantPendingMessageLimitStrategy limit="0"/>
> >> </pendingMessageLimitStrategy>
> >> </policyEntry>
> >> </policyEntries></policyMap>
> >> </destinationPolicy>
> >>
> >> </broker>
> >>
> >> </beans>
> >>
> >> queuePrefetch property of resource adapter doesnt help.
> >> and it really is 10 !
> >> it not only that it behaves like it is 10. thats what i can see via jmx.
> >>
> >>
> >> About lost messages. Yup, I applied AMQ-1078 to 4.1 and problem
> >> disappeared.
> >>
> >>
> >> James.Strachan wrote:
> >> >
> >> > On 1/25/07, magic.moose <ma...@avedya.com> wrote:
> >> >>
> >> >> Hi.
> >> >>
> >> >> AMQ4.1.0, Jencks, Spring 1.2.7.
> >> >>
> >> >> Prefetch size for all queues is always 10. I tried to CHANGE it in
> >> many
> >> >> places:
> >> >> - in broker url (both in conf xml and embedded into
> >> connectionFactory).
> >> >> - in activationSpec destination name.
> >> >> - in xml config <queue> (name || physicalName ??).
> >> >>
> >> >> It stays 10...
> >> >
> >> > The default is 1000 BTW.
> >> >
> >> >
> >> http://svn.apache.org/repos/asf/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQPrefetchPolicy.java
> >> >
> >> >
> >> >> Broker is embedded, jvm. no persistance. Is there any other place?
> >> >> something
> >> >> overides my settings? Its crazy. such a simple thing to do and takes
> >> >> ages...
> >> >
> >> > Given that you're using Jencks and so JCA, it should be the Resource
> >> > Adapter settings
> >> > http://activemq.apache.org/resource-adapter-properties.html
> >> >
> >> >
> >> >> BTW: I want to play with that setting to deal with very slow
> >> consumers.
> >> >> Im
> >> >> loosing some messages (or rather they are stuck in the queue) when I
> >> bulk
> >> >> send them.
> >> >
> >> > FWIW this has been fixed in 4.2 if you wanna try that
> >> >
> >> > --
> >> >
> >> > James
> >> > -------
> >> > http://radio.weblogs.com/0112098/
> >> >
> >> >
> >>
> >> --
> >> View this message in context:
> >> http://www.nabble.com/Can%27t-set-prefetch-size%21-tf3114996.html#a8763926
> >> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
> >>
> >>
> >
> >
> > --
> >
> > James
> > -------
> > http://radio.weblogs.com/0112098/
> >
> >
> >
>
> --
> View this message in context: http://www.nabble.com/Can%27t-set-prefetch-size%21-tf3114996.html#a8802895
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>
--
James
-------
http://radio.weblogs.com/0112098/
Re: Can't set prefetch size!
Posted by "magic.moose" <ma...@avedya.com>.
Yes, I just wanted to show config w/o prefetch stuff.
Anyway, setting vm://localhost?jms.prefetchPolicy.all, or policies for
queues, or for particular consumer via URL it all failed.
So did setting of resource adapter properties according to
http://activemq.apache.org/resource-adapter-properties.html.
Weird thing is that 'default value' is 1000, well, at least in docs. Ive
never ever seen 1000 while playing with 4.1 and jvm transport. Always 10.
I havent tried to force it in code. I really dont want to go that way
though.
In fact there is no more config I use. Well activationSpec, maybe, for some
consumer props. It works on default settings though...
Maciek
James.Strachan wrote:
>
> On 2/2/07, magic.moose <ma...@avedya.com> wrote:
>>
>>
>> I tried that. Resource Adapter simply references connectionFactory:
>
> I'm confused - I don't see any attempt to set the prefetch policy in
> your XML? If you are explicitly creating a connectionFactory and
> passing it into the RA you could try configure that?
>
> James
>
>
>> <bean id="broker"
>> class="org.apache.activemq.xbean.BrokerFactoryBean"
>> depends-on="serverConnector">
>> <property name="config"
>> value="classpath:broker.xml" />
>> <property name="start" value="true" />
>> </bean>
>> <bean id="connectionFactory"
>> class="org.apache.activemq.ActiveMQConnectionFactory"
>> singleton="true">
>> <property name="brokerURL" value="vm://localhost"/>
>> </bean>
>>
>> <bean id="jmsResourceAdapter"
>> class="org.apache.activemq.ra.ActiveMQResourceAdapter">
>> <property name="connectionFactory"
>> ref="connectionFactory" />
>> </bean>
>>
>> where broker.xml:
>> <?xml version="1.0" encoding="UTF-8"?>
>>
>> <beans xmlns="http://activemq.org/config/1.0">
>>
>> <broker name="localhost" persistent="false" useJmx="true">
>>
>> <transportConnectors>
>> <transportConnector
>> uri="vm://localhost" />
>> </transportConnectors>
>> <memoryManager>
>> <usageManager id="memory-manager" limit="20 MB"
>> />
>> </memoryManager>
>>
>> <destinationPolicy>
>> <policyMap><policyEntries>
>> <policyEntry queue="testQueue">
>> <dispatchPolicy>
>> <roundRobinDispatchPolicy/>
>> </dispatchPolicy>
>> <pendingMessageLimitStrategy>
>> <constantPendingMessageLimitStrategy limit="0"/>
>> </pendingMessageLimitStrategy>
>> </policyEntry>
>> </policyEntries></policyMap>
>> </destinationPolicy>
>>
>> </broker>
>>
>> </beans>
>>
>> queuePrefetch property of resource adapter doesnt help.
>> and it really is 10 !
>> it not only that it behaves like it is 10. thats what i can see via jmx.
>>
>>
>> About lost messages. Yup, I applied AMQ-1078 to 4.1 and problem
>> disappeared.
>>
>>
>> James.Strachan wrote:
>> >
>> > On 1/25/07, magic.moose <ma...@avedya.com> wrote:
>> >>
>> >> Hi.
>> >>
>> >> AMQ4.1.0, Jencks, Spring 1.2.7.
>> >>
>> >> Prefetch size for all queues is always 10. I tried to CHANGE it in
>> many
>> >> places:
>> >> - in broker url (both in conf xml and embedded into
>> connectionFactory).
>> >> - in activationSpec destination name.
>> >> - in xml config <queue> (name || physicalName ??).
>> >>
>> >> It stays 10...
>> >
>> > The default is 1000 BTW.
>> >
>> >
>> http://svn.apache.org/repos/asf/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQPrefetchPolicy.java
>> >
>> >
>> >> Broker is embedded, jvm. no persistance. Is there any other place?
>> >> something
>> >> overides my settings? Its crazy. such a simple thing to do and takes
>> >> ages...
>> >
>> > Given that you're using Jencks and so JCA, it should be the Resource
>> > Adapter settings
>> > http://activemq.apache.org/resource-adapter-properties.html
>> >
>> >
>> >> BTW: I want to play with that setting to deal with very slow
>> consumers.
>> >> Im
>> >> loosing some messages (or rather they are stuck in the queue) when I
>> bulk
>> >> send them.
>> >
>> > FWIW this has been fixed in 4.2 if you wanna try that
>> >
>> > --
>> >
>> > James
>> > -------
>> > http://radio.weblogs.com/0112098/
>> >
>> >
>>
>> --
>> View this message in context:
>> http://www.nabble.com/Can%27t-set-prefetch-size%21-tf3114996.html#a8763926
>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>
>>
>
>
> --
>
> James
> -------
> http://radio.weblogs.com/0112098/
>
>
>
--
View this message in context: http://www.nabble.com/Can%27t-set-prefetch-size%21-tf3114996.html#a8802895
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Can't set prefetch size!
Posted by James Strachan <ja...@gmail.com>.
On 2/2/07, magic.moose <ma...@avedya.com> wrote:
>
>
> I tried that. Resource Adapter simply references connectionFactory:
I'm confused - I don't see any attempt to set the prefetch policy in
your XML? If you are explicitly creating a connectionFactory and
passing it into the RA you could try configure that?
James
> <bean id="broker"
> class="org.apache.activemq.xbean.BrokerFactoryBean"
> depends-on="serverConnector">
> <property name="config"
> value="classpath:broker.xml" />
> <property name="start" value="true" />
> </bean>
> <bean id="connectionFactory"
> class="org.apache.activemq.ActiveMQConnectionFactory"
> singleton="true">
> <property name="brokerURL" value="vm://localhost"/>
> </bean>
>
> <bean id="jmsResourceAdapter"
> class="org.apache.activemq.ra.ActiveMQResourceAdapter">
> <property name="connectionFactory" ref="connectionFactory" />
> </bean>
>
> where broker.xml:
> <?xml version="1.0" encoding="UTF-8"?>
>
> <beans xmlns="http://activemq.org/config/1.0">
>
> <broker name="localhost" persistent="false" useJmx="true">
>
> <transportConnectors>
> <transportConnector
> uri="vm://localhost" />
> </transportConnectors>
> <memoryManager>
> <usageManager id="memory-manager" limit="20 MB" />
> </memoryManager>
>
> <destinationPolicy>
> <policyMap><policyEntries>
> <policyEntry queue="testQueue">
> <dispatchPolicy>
> <roundRobinDispatchPolicy/>
> </dispatchPolicy>
> <pendingMessageLimitStrategy>
> <constantPendingMessageLimitStrategy limit="0"/>
> </pendingMessageLimitStrategy>
> </policyEntry>
> </policyEntries></policyMap>
> </destinationPolicy>
>
> </broker>
>
> </beans>
>
> queuePrefetch property of resource adapter doesnt help.
> and it really is 10 !
> it not only that it behaves like it is 10. thats what i can see via jmx.
>
>
> About lost messages. Yup, I applied AMQ-1078 to 4.1 and problem
> disappeared.
>
>
> James.Strachan wrote:
> >
> > On 1/25/07, magic.moose <ma...@avedya.com> wrote:
> >>
> >> Hi.
> >>
> >> AMQ4.1.0, Jencks, Spring 1.2.7.
> >>
> >> Prefetch size for all queues is always 10. I tried to CHANGE it in many
> >> places:
> >> - in broker url (both in conf xml and embedded into connectionFactory).
> >> - in activationSpec destination name.
> >> - in xml config <queue> (name || physicalName ??).
> >>
> >> It stays 10...
> >
> > The default is 1000 BTW.
> >
> > http://svn.apache.org/repos/asf/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQPrefetchPolicy.java
> >
> >
> >> Broker is embedded, jvm. no persistance. Is there any other place?
> >> something
> >> overides my settings? Its crazy. such a simple thing to do and takes
> >> ages...
> >
> > Given that you're using Jencks and so JCA, it should be the Resource
> > Adapter settings
> > http://activemq.apache.org/resource-adapter-properties.html
> >
> >
> >> BTW: I want to play with that setting to deal with very slow consumers.
> >> Im
> >> loosing some messages (or rather they are stuck in the queue) when I bulk
> >> send them.
> >
> > FWIW this has been fixed in 4.2 if you wanna try that
> >
> > --
> >
> > James
> > -------
> > http://radio.weblogs.com/0112098/
> >
> >
>
> --
> View this message in context: http://www.nabble.com/Can%27t-set-prefetch-size%21-tf3114996.html#a8763926
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
>
--
James
-------
http://radio.weblogs.com/0112098/
Re: Can't set prefetch size!
Posted by "magic.moose" <ma...@avedya.com>.
I tried that. Resource Adapter simply references connectionFactory:
<bean id="broker"
class="org.apache.activemq.xbean.BrokerFactoryBean"
depends-on="serverConnector">
<property name="config"
value="classpath:broker.xml" />
<property name="start" value="true" />
</bean>
<bean id="connectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory"
singleton="true">
<property name="brokerURL" value="vm://localhost"/>
</bean>
<bean id="jmsResourceAdapter"
class="org.apache.activemq.ra.ActiveMQResourceAdapter">
<property name="connectionFactory" ref="connectionFactory" />
</bean>
where broker.xml:
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://activemq.org/config/1.0">
<broker name="localhost" persistent="false" useJmx="true">
<transportConnectors>
<transportConnector
uri="vm://localhost" />
</transportConnectors>
<memoryManager>
<usageManager id="memory-manager" limit="20 MB" />
</memoryManager>
<destinationPolicy>
<policyMap><policyEntries>
<policyEntry queue="testQueue">
<dispatchPolicy>
<roundRobinDispatchPolicy/>
</dispatchPolicy>
<pendingMessageLimitStrategy>
<constantPendingMessageLimitStrategy limit="0"/>
</pendingMessageLimitStrategy>
</policyEntry>
</policyEntries></policyMap>
</destinationPolicy>
</broker>
</beans>
queuePrefetch property of resource adapter doesnt help.
and it really is 10 !
it not only that it behaves like it is 10. thats what i can see via jmx.
About lost messages. Yup, I applied AMQ-1078 to 4.1 and problem
disappeared.
James.Strachan wrote:
>
> On 1/25/07, magic.moose <ma...@avedya.com> wrote:
>>
>> Hi.
>>
>> AMQ4.1.0, Jencks, Spring 1.2.7.
>>
>> Prefetch size for all queues is always 10. I tried to CHANGE it in many
>> places:
>> - in broker url (both in conf xml and embedded into connectionFactory).
>> - in activationSpec destination name.
>> - in xml config <queue> (name || physicalName ??).
>>
>> It stays 10...
>
> The default is 1000 BTW.
>
> http://svn.apache.org/repos/asf/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQPrefetchPolicy.java
>
>
>> Broker is embedded, jvm. no persistance. Is there any other place?
>> something
>> overides my settings? Its crazy. such a simple thing to do and takes
>> ages...
>
> Given that you're using Jencks and so JCA, it should be the Resource
> Adapter settings
> http://activemq.apache.org/resource-adapter-properties.html
>
>
>> BTW: I want to play with that setting to deal with very slow consumers.
>> Im
>> loosing some messages (or rather they are stuck in the queue) when I bulk
>> send them.
>
> FWIW this has been fixed in 4.2 if you wanna try that
>
> --
>
> James
> -------
> http://radio.weblogs.com/0112098/
>
>
--
View this message in context: http://www.nabble.com/Can%27t-set-prefetch-size%21-tf3114996.html#a8763926
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Can't set prefetch size!
Posted by James Strachan <ja...@gmail.com>.
On 1/25/07, magic.moose <ma...@avedya.com> wrote:
>
> Hi.
>
> AMQ4.1.0, Jencks, Spring 1.2.7.
>
> Prefetch size for all queues is always 10. I tried to CHANGE it in many
> places:
> - in broker url (both in conf xml and embedded into connectionFactory).
> - in activationSpec destination name.
> - in xml config <queue> (name || physicalName ??).
>
> It stays 10...
The default is 1000 BTW.
http://svn.apache.org/repos/asf/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQPrefetchPolicy.java
> Broker is embedded, jvm. no persistance. Is there any other place? something
> overides my settings? Its crazy. such a simple thing to do and takes ages...
Given that you're using Jencks and so JCA, it should be the Resource
Adapter settings
http://activemq.apache.org/resource-adapter-properties.html
> BTW: I want to play with that setting to deal with very slow consumers. Im
> loosing some messages (or rather they are stuck in the queue) when I bulk
> send them.
FWIW this has been fixed in 4.2 if you wanna try that
--
James
-------
http://radio.weblogs.com/0112098/