From dev-return-8984-apmail-activemq-dev-archive=activemq.apache.org@activemq.apache.org Thu Dec 06 19:30:51 2007 Return-Path: Delivered-To: apmail-activemq-dev-archive@www.apache.org Received: (qmail 19752 invoked from network); 6 Dec 2007 19:30:51 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 6 Dec 2007 19:30:51 -0000 Received: (qmail 65865 invoked by uid 500); 6 Dec 2007 19:30:39 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 65831 invoked by uid 500); 6 Dec 2007 19:30:39 -0000 Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list dev@activemq.apache.org Received: (qmail 65822 invoked by uid 99); 6 Dec 2007 19:30:39 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 06 Dec 2007 11:30:39 -0800 X-ASF-Spam-Status: No, hits=-100.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO brutus.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 06 Dec 2007 19:30:48 +0000 Received: from brutus (localhost [127.0.0.1]) by brutus.apache.org (Postfix) with ESMTP id 44EFD714254 for ; Thu, 6 Dec 2007 11:30:27 -0800 (PST) Message-ID: <16830682.1196969427278.JavaMail.jira@brutus> Date: Thu, 6 Dec 2007 11:30:27 -0800 (PST) From: "Jose Urzua (JIRA)" To: dev@activemq.apache.org Subject: [jira] Commented: (AMQ-1505) Durable/Persistant topics via Stomp on 5.0 snapshot don't seem to work In-Reply-To: <19502528.1196177006762.JavaMail.jira@brutus> MIME-Version: 1.0 Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: 7bit X-Virus-Checked: Checked by ClamAV on apache.org [ https://issues.apache.org/activemq/browse/AMQ-1505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#action_40805 ] Jose Urzua commented on AMQ-1505: --------------------------------- Hi I'm using "persistent" instead of "persist" and it works fine: $stomp->send( { destination => '/topic/foo', body => 'test message', persistent => 'true' } ); and I'm using postgres and mysql persistenceAdapter and apache-activemq-5.0-20071128.111935-4 > Durable/Persistant topics via Stomp on 5.0 snapshot don't seem to work > ---------------------------------------------------------------------- > > Key: AMQ-1505 > URL: https://issues.apache.org/activemq/browse/AMQ-1505 > Project: ActiveMQ > Issue Type: Bug > Components: Broker > Affects Versions: 5.0.0 > Environment: Linux, Centos-4 (RHEL clone), activemq snapshot (apache-activemq-5.0-20071120.092745) > Reporter: Alex Tang > > I noticed a problem where durable/persistent topic messages are not being sent to offline consumers in 5.0 when the consumer is reconnected. > The following test code works in activemq-4.1.1, but does not in 5.0-snapshot (5.0-20071120.092745) > I have the following test perl code using Net::Stomp > #publisher > use strict; > use warnings; > use Net::Stomp; > my $stomp = Net::Stomp->new( { hostname => 'localhost', port => '61613' } ); > $stomp->connect( { login => 'hello', passcode => 'there' } ); > $stomp->send( { destination => '/topic/foo', body => 'test message', persist => 'true' } ); > $stomp->disconnect; > And the following consumer: > # subscribe to messages from the topic 'foo' > use strict; > use warnings; > use Net::Stomp; > my $stomp = Net::Stomp->new( { hostname => 'localhost', port => '61613' } ); > $stomp->connect ( > { > login => 'hello', > passcode => 'there' , > 'client-id' => 'tango', > } > ); > $stomp->subscribe( > { destination => '/topic/foo', > 'ack' => 'client', > 'activemq.prefetchSize' => 1, > 'activemq.subscriptionName' => 'tango', > } > ); > while (1) { > my $frame = $stomp->receive_frame; > warn $frame->body; # do something here > $stomp->ack( { frame => $frame } ); > } > $stomp->disconnect; > On activemq 4.1.1, the subscription is durable/persistent (i can disconnect the consumer and any messages sent by the producer will be received by the consumer when the consumer is reconnected). However, on the 5.0 snapshot, i cannot get any messages that are sent by the producer when the consumer is offline to be received by the consumer when the consumer is reconnected. -- This message is automatically generated by JIRA. - You can reply to this email to add a comment to the issue online.