[
https://issues.apache.org/jira/browse/AMQ-6240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gary Tully reassigned AMQ-6240:
-------------------------------
Assignee: Gary Tully
> Producer cannot be terminated when slow consumer is detected
> ------------------------------------------------------------
>
> Key: AMQ-6240
> URL: https://issues.apache.org/jira/browse/AMQ-6240
> Project: ActiveMQ
> Issue Type: Bug
> Components: Connector
> Affects Versions: 5.13.2
> Environment: The test was run using an out of the box install of
> ActiveMQ 5.13.2 on Windows 7 Professional (64 bit).
> The java version used was jdk1.8.0_60
> Reporter: Ken Hall
> Assignee: Gary Tully
> Attachments: brokertd.zip
>
>
> There is a discussion relating to the bug here -
> http://activemq.2283324.n4.nabble.com/Force-Producer-to-fail-when-blocked-by-slow-consumer-td4710264.html.
> Test code to reproduce the problem has also been uploaded to this
> discussion.
> We have a situation where we have a producer which is feeding a slow
> consumer.
> The consumer belongs to a third party so we do not have control over the
> broker configuration.
> We would like to terminate our producer but we find that we cannot do so. We
> can set the timeout on the connection and we then trap the timeout exception.
> The problem is that when we try to close the session it attempts to rollback
> but cannot do so as the rollback blocks.
> We have created a small test that is included in the zip (mentioned above) of
> an Eclipse project.The zip includes three classes. Call the main method of
> RunTest to run the test. The activemq.xml used is in the root directory of
> the project.
> The program will timeout after 51 messages and attempt to close the session.
> It eventually locks in this line:
> this.connection.syncSendPacket(info);
> in the rollback method of the TransactionContext class.
> We believe that the most sensible solution to this is that the rollback
> should respond to the same timeout as the connection.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
