Hi all,

I'm trying to use Net::Stomp as a simple means of consuming from an ActiveMQ queue.

If there are no frames on the queue, I want the consumer script to quit or move onto other things.

I tried this:

use Net::Stomp;

my $hostname = 'localhost';

warn "Creating stomp object";
my $stomp = Net::Stomp->new( { hostname => $hostname, port => '61613' 
+} );

warn "Connecting";
$stomp->connect( { login => 'guest', passcode => 'password' } );

warn "Subscribing";
$stomp->subscribe( { destination => '/queue/example.A',
                     'activemq.prefetchSize' => 1 });

while ( $stomp->can_read ){
    warn "Getting frame";
    my $frame = $stomp->receive_frame ( { timeout => 0.5 } ) || die 'f
+rame timeout';
    warn 'Got frame: ' . $frame->body;
 }

$stomp->disconnect;
warn "Disconnected";
[download]

This gets frames while there are frames to be read (good). But then it waits indefinitely for the next frame (bad).

Got frame: This is message 10 at ./stomp_consumer.pl line 26.
Getting frame at ./stomp_consumer.pl line 24.
[download]

According to the documentation, it should also be possible to set timeout behaviour with the can_read method

while ( $stomp->can_read ( {timeout => 0.5 } ) ){
# do stuff
}
[download]

This is also ineffective (no timeout).

Am I missing something obvious? If so, please accept my apologies.

All suggestions gratefully received.