You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by "Hiram Chirino (Updated) (JIRA)" <ji...@apache.org> on 2011/12/12 22:01:33 UTC
[jira] [Updated] (APLO-88) ACK followed by DISCONNECT Leaves
Message Available
[ https://issues.apache.org/jira/browse/APLO-88?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Hiram Chirino updated APLO-88:
------------------------------
Affects Version/s: 1.0-beta6
Fix Version/s: 1.0
Assignee: Hiram Chirino
I've just created a test case which reproduces. I'm going to start working on the fix. Thanks for all the info.
> ACK followed by DISCONNECT Leaves Message Available
> ---------------------------------------------------
>
> Key: APLO-88
> URL: https://issues.apache.org/jira/browse/APLO-88
> Project: ActiveMQ Apollo
> Issue Type: Bug
> Components: apollo-stomp
> Affects Versions: 1.0-beta6
> Environment: Linux, Ubuntu 11.04
> Reporter: Guy Allard
> Assignee: Hiram Chirino
> Fix For: 1.0
>
> Attachments: aplo-88-log.txt
>
>
> An ACK (client mode) followed by a DISCONNECT with no wait time between the frames appears to leave message on the queue.
> I am seeing this with apache-apollo-1.0-20111012.032531-204-unix-distro.tar.gz and at least one previous snapshot.
> I stumbled on to this while working on a new 1.1 client in go. It occurs with either a 1.0 or 1.1 connection. The go code is very raw and not publicly available yet.
> However it recreates with 1.0 using the Ruby stomp gem. Code to recreate:
> # ---------
> require 'rubygems'
> require 'stomp'
> #
> c = Stomp::Connection.open('my', 'mypw', 'localhost', 62613) # Apollo is here
> c.subscribe "/queue/rtest.01", :ack => :client
> c.publish "/queue/rtest.01", "a simple message"
> msg = c.receive
> c.ack msg.headers['message-id']
> # sleep 5
> c.disconnect
> # ---------
> And is (usually) accompanied by:
> 2011-10-13 22:56:00,041 | DEBUG | Internal protocol error: message delivery acked/nacked multiple times: 1 | org.apache.activemq.apollo.broker.Subscription | hawtdispatch-DEFAULT-1
> in apollo.log
> Calling 'flush' on the socket seems to have no affect (in either Ruby or go).
> If you uncomment the 'sleep' in the above Ruby code, the problem will (usually) *not* occur.
> I do get some slightly different results with the go test bed, but let's start with this ............
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira