[
https://issues.apache.org/activemq/browse/AMQ-1764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=43188#action_43188
]
armgong edited comment on AMQ-1764 at 6/4/08 5:44 PM:
------------------------------------------------------
it seems https://issues.apache.org/activemq/browse/AMQ-1136
btw the attach file is includes the activemq config file activemq.xml and
producer (in producer dir )and slow consumer application (in slow dir). the two
applications user none_durable topic "chatTopic.chatMessage"
if configured in activemq as following :
<destinations>
<topic physicalName="chatTopic.chatMessage" />
</destinations>
<!-- Destination specific policies using destination names or wildcards
-->
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry queue=">" memoryLimit="20mb"/>
<policyEntry topic="chatTopic.chatMessage"
memoryLimit="64mb">
<dispatchPolicy>
<strictOrderDispatchPolicy/>
</dispatchPolicy>
<subscriptionRecoveryPolicy>
<lastImageSubscriptionRecoveryPolicy/>
</subscriptionRecoveryPolicy>
<!--slow consumer policy-->
<pendingMessageLimitStrategy>
<constantPendingMessageLimitStrategy limit="10"/>
</pendingMessageLimitStrategy>
</policyEntry>
</policyEntries>
</policyMap>
</destinationPolicy>
was (Author: armgong):
btw the attach file is includes the activemq config file activemq.xml and
producer (in producer dir )and slow consumer application (in slow dir). the two
applications user none_durable topic "chatTopic.chatMessage"
if configured in activemq as following :
<destinations>
<topic physicalName="chatTopic.chatMessage" />
</destinations>
<!-- Destination specific policies using destination names or wildcards
-->
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry queue=">" memoryLimit="20mb"/>
<policyEntry topic="chatTopic.chatMessage"
memoryLimit="64mb">
<dispatchPolicy>
<strictOrderDispatchPolicy/>
</dispatchPolicy>
<subscriptionRecoveryPolicy>
<lastImageSubscriptionRecoveryPolicy/>
</subscriptionRecoveryPolicy>
<!--slow consumer policy-->
<pendingMessageLimitStrategy>
<constantPendingMessageLimitStrategy limit="10"/>
</pendingMessageLimitStrategy>
</policyEntry>
</policyEntries>
</policyMap>
</destinationPolicy>
> strange slower consumer and borker problem,make slow consumer application and
> broker memory grow very fast
> ----------------------------------------------------------------------------------------------------------
>
> Key: AMQ-1764
> URL: https://issues.apache.org/activemq/browse/AMQ-1764
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.1.0
> Environment: win2003sp2 , activemq 5.10 ,jdk6.0update6
> Reporter: armgong
> Attachments: test.zip
>
>
> I write a fast producer(produce a message take 1 ms) and a slow
> consumer(consumer a message take 10 seconds) application,and config
> standalone activemq through activemq.xml,in the activemq.xml I config
> constantPendingMessageLimitStrategy limit="10",and in the slow consumer i
> config connection url is
> "tcp://127.0.0.1:61616?jms.prefetchPolicy.queuePrefetch=50".
> but the strange problem happends when i want send 200k 512 bytes size
> messages to borker through fast producer.
> when producer send messages start,the borker and the slow consumer memory
> useage grow very fast,after send 120k messages, the slow consumer take 80MB
> memory from at application start 18MB memory,and borker take 140MB memory,
> then borker slowing down,and totaly freeze.
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
