[ 
https://issues.apache.org/activemq/browse/AMQ-2564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=56875#action_56875
 ] 

Jörn Kottmann commented on AMQ-2564:
------------------------------------

I added the  sendFailIfNoSpace="true" attribute to the systemUsage element of 
he slave broker config, repeated the test and the following exception was 
printed to the console of the master broker:

ERROR | Slave Failed
javax.jms.ResourceAllocationException: Usage Manager Store is Full. Producer 
(ID:karkand-45529-1263315817291-0:0:1:1) stopped to prevent flooding 
queue://TestQueue. See http://activemq.apache.org/producer-flow-control.html 
for more info
        at org.apache.activemq.broker.region.Queue.doMessageSend(Queue.java:500)
        at org.apache.activemq.broker.region.Queue.send(Queue.java:474)
        at 
org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.java:354)
        at 
org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:445)
        at 
org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java:224)
        at org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:126)
        at 
org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDestinationBroker.java:95)
        at 
org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:133)
        at 
org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:443)
        at 
org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:631)
        at 
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:297)
        at 
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:175)
        at 
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)
        at 
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
        at 
org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:207)
        at 
org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:98)
        at 
org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:36)

> Pure Master Slave broker hangs when storage limit is reached
> ------------------------------------------------------------
>
>                 Key: AMQ-2564
>                 URL: https://issues.apache.org/activemq/browse/AMQ-2564
>             Project: ActiveMQ
>          Issue Type: Bug
>          Components: Broker
>    Affects Versions: 5.3.0
>         Environment: Ubuntu 9.10 Desktop, Java 1.6 (build 1.6.0_16-b01)
>            Reporter: Jörn Kottmann
>            Priority: Minor
>         Attachments: activemq-master.xml, activemq-slave.xml
>
>
> The pure master slave broker hangs when the storage limit is reached and 
> dequeueing messages from the queue is not possible.
> The behavior can be reproduced with a producer which sends messages to the 
> master broker until the slave broker writes
>  "INFO | Usage Manager Store is Full. Stopping producer 
> (ID:karkand-51292-1263305705067-0:0:1:1) to prevent flooding 
> queue://TestQueue. See http://activemq.apache.org/producer-flow-control.html 
> for more info"
> this message to the console.
> To reproduce the store is full message on the slave broker maybe 2 - 3 
> attempts are necessary otherwise
> the messages appears on the console of the master broker.
> Any attempts by a test consumer to dequeue messages fail, it just hangs.
> The following information gather with JMX might be interesting:
> MASTER: StorePercentUsage=99
> SLAVE:    StorePercentUsage=100
> The attributes for the Queue are identical on both 
> brokers.

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.

Reply via email to