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:
This gets frames while there are frames to be read (good). But then it waits indefinitely for the next frame (bad).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";
According to the documentation, it should also be possible to set timeout behaviour with the can_read methodGot frame: This is message 10 at ./stomp_consumer.pl line 26. Getting frame at ./stomp_consumer.pl line 24.
This is also ineffective (no timeout).while ( $stomp->can_read ( {timeout => 0.5 } ) ){ # do stuff }
Am I missing something obvious? If so, please accept my apologies.
All suggestions gratefully received.
| For: | Use: | ||
| & | & | ||
| < | < | ||
| > | > | ||
| [ | [ | ||
| ] | ] |