On 2/2/07, magic.moose <[EMAIL PROTECTED]> 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 <[EMAIL PROTECTED]> 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/
