qpid-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF subversion and git services (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (QPID-6252) AMQP 1.0 browsing client generates large number of errors on broker.
Date Mon, 01 Dec 2014 17:42:12 GMT

    [ https://issues.apache.org/jira/browse/QPID-6252?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14230094#comment-14230094
] 

ASF subversion and git services commented on QPID-6252:
-------------------------------------------------------

Commit 1642720 from [~aconway] in branch 'qpid/trunk'
[ https://svn.apache.org/r1642720 ]

QPID-6252: AMQP 1.0 browsing client generates large number of errors on broker.

The problem was that messages for browsing receivers were being recorded on the
client SessionContext unacked list. This is incorrect since you don't ack
browsed messages.  They remained on the list after the browsing receiver was
closed, and every subsequent call to acknowledge() on the client would attempt
to ack these messages for a no-longer-existing link. Fix is to not record
browsed messages.

> AMQP 1.0 browsing client generates large number of errors on broker.
> --------------------------------------------------------------------
>
>                 Key: QPID-6252
>                 URL: https://issues.apache.org/jira/browse/QPID-6252
>             Project: Qpid
>          Issue Type: Bug
>          Components: C++ Client
>    Affects Versions: 0.31
>            Reporter: Alan Conway
>            Assignee: Alan Conway
>
>  An AMQP 1.0 client that uses a mixtiure of browsing and acquiring receivers on the same
session generates spurious error messages in the broker log like this:
> [Broker] error Delivery returned for unknown link
> The following python program illustrates the problem.
> ----
> from qpid_messaging import *
> c = Connection.establish("localhost", protocol="amqp1.0")
> ssn = c.session()
> ssn.sender("foo;{create:always}").send("foo")
> r = ssn.receiver("foo;{mode:browse}")
> r.fetch().content
> r.close()
> ssn.acknowledge()



--
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