You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Alex Tang (JIRA)" <ji...@apache.org> on 2007/11/27 16:23:26 UTC
[jira] Created: (AMQ-1505) Durable/Persistant topics via Stomp on
5.0 snapshot don't seem to work
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.
[jira] Commented: (AMQ-1505) Durable/Persistant topics via Stomp on
5.0 snapshot don't seem to work
Posted by "Jose Urzua (JIRA)" <ji...@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.
[jira] Resolved: (AMQ-1505) Durable/Persistant topics via Stomp on
5.0 snapshot don't seem to work
Posted by "Timothy Bish (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/activemq/browse/AMQ-1505?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Timothy Bish resolved AMQ-1505.
-------------------------------
Resolution: Fixed
Similar tests using the C++ and .NET clients for durable subscriptions work fine on 5.3 and 5.4-SNAPSHOTs
> 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
> Fix For: 5.4.0
>
>
> 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.