MQSeries::Queue MQSeries::Queue is a OO interface to the MQSeries Queue objects.
Download

MQSeries::Queue Ranking & Summary

MQSeries::Queue Tags

Perl module interface MQSeries OO OO interface MQSeries objects

MQSeries::Queue Description

MQSeries::Queue is a OO interface to the MQSeries Queue objects. MQSeries::Queue is a OO interface to the MQSeries Queue objects.SYNOPSIS use MQSeries; use MQSeries::Queue; use MQSeries::Message; # # Open a queue for output, loop getting messages, updating some # database with the data. # my $queue = MQSeries::Queue->new ( QueueManager => 'some.queue.manager', Queue => 'SOME.QUEUE', Mode => 'input_exclusive', ) or die("Unable to open queue.n"); while ( 1 ) { my $getmessage = MQSeries::Message->new; $queue->Get ( Message => $getmessage, Sync => 1, ) or die("Unable to get messagen" . "CompCode = " . $queue->CompCode() . "n" . "Reason = " . $queue->Reason() . "n"); if ( UpdateSomeDatabase($getmessage->Data()) ) { $queue->QueueManager()->Commit() or die("Unable to commit changes to queue.n" . "CompCode = " . $queue->CompCode() . "n" . "Reason = " . $queue->Reason() . "n"); } else { $queue->QueueManager()->Backout() or die("Unable to backout changes to queue.n" . "CompCode = " . $queue->CompCode() . "n" . "Reason = " . $queue->Reason() . "n"); } } # # Put a message into the queue, using Storable to allow use of # references as message data. (NOTE: this is done for you if use the # MQSeries::Message::Storable class.) # use Storable; my $queue = MQSeries::Queue->new ( QueueManager => 'some.queue.manager', Queue => 'SOME.QUEUE', Mode => 'output', PutConvert => &Storable::nfreeze, GetConvert => &Storable::thaw, ) or die("Unable to open queue.n"); my $putmessage = MQSeries::Message->new ( Data => { a => , e => { f => "Huh?", g => "Wow!", }, h => 42, }, ); $queue->Put( Message => $putmessage ) or die("Unable to put message onto queue.n" . "CompCode = " . $queue->CompCode() . "n" . "Reason = " . $queue->Reason() . "n"); # # Alternate mechanism for specifying the conversion routines. # my $queue = MQSeries::Queue->new ( QueueManager => 'some.queue.manager', Queue => 'SOME.QUEUE', Mode => 'output', ) or die("Unable to open queue.n"); my $putmessage = MQSeries::Message->new ( Data => { a => , e => { f => "Huh?", g => "Wow!", }, h => 42, }, ); $queue->Put( Message => $putmessage PutConvert => &Storable::freeze, ) or die("Unable to put message onto queue.n" . "CompCode = " . $queue->CompCode() . "n" . "Reason = " . $queue->Reason() . "n"); Requirements: · Perl

MQSeries::Queue Related Software