Hi,
It could be nice to add an input source in a future version, reading
an ActiveMQ queue.
If that can help :
--> Library used to read in ActiveMQ :
use Net::Stomp;
--> Connection to the activeMQ server
my $stomp_in = Net::Stomp->new( { hostname => $AMQ_SERVER, port =>
$AMQ_PORT } );
$stomp_in->connect();
--> Connection to a specific queue
$stomp_in->subscribe(
{ destination => '/queue/'.$AMQ_QUEUE_FROM,
'ack' => 'client',
'activemq.prefetchSize' => 1
}
);
--> Reading into the queue
my $frame;
if ($stomp_in->can_read)
{
$frame = $stomp_in->receive_frame;
log_msg(LOG_NOTICE,"[READ FROM ACTIVEMQ]",$frame->body);
$line = $frame->body;
}
--> Acknowledge the message when it was performed
$stomp_in->ack( { frame => $frame } );
Best regards,
Antonin.
------------------------------------------------------------------------------
Throughout its 18-year history, RSA Conference consistently attracts the
world's best and brightest in the field, creating opportunities for Conference
attendees to learn about information security's most important issues through
interactions with peers, luminaries and emerging and established companies.
http://p.sf.net/sfu/rsaconf-dev2dev
_______________________________________________
Simple-evcorr-users mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/simple-evcorr-users
