qpid-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Rob Godfrey (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (QPID-6817) [Java Broker] On abrupt connection close from client side when Broker is deliverying messages to consumer the delivering messages might not be released as part of close in some unlucky circumstances
Date Mon, 22 Feb 2016 10:06:18 GMT

     [ https://issues.apache.org/jira/browse/QPID-6817?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Rob Godfrey updated QPID-6817:
------------------------------
    Status: Reviewable  (was: In Progress)

> [Java Broker] On abrupt connection close from client side when Broker is deliverying
messages to consumer the delivering messages might not be released as part of close in some
unlucky circumstances
> ------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
>
>                 Key: QPID-6817
>                 URL: https://issues.apache.org/jira/browse/QPID-6817
>             Project: Qpid
>          Issue Type: Bug
>          Components: Java Broker
>    Affects Versions: qpid-java-6.0
>            Reporter: Alex Rudyy
>            Assignee: Rob Godfrey
>            Priority: Blocker
>             Fix For: qpid-java-6.1
>
>
> With current implementation consumer acquired messages are put into intermediate queue
on ConsumerTarget before putting them into wire. The registering of those messages as unacknowledged
 with session  happens letter. When TCP connection is get closed between message being put
into a ConsumerTarget queue and registering of it on session as unacknowledged, such message
cannot be released as part of session close and can continue remain in ACQUIRED state blocking
the queue message flow. Only Broker restart can remediate the issue.
> It seems we can fix the issue by introducing a method on a  ConsumerTarget to iterate
over the messages stored in intermediate queue and call release method on them. The method
shall be invoked as part of ConsumerTarget close.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@qpid.apache.org
For additional commands, e-mail: dev-help@qpid.apache.org


Mime
View raw message