MQSeries::QueueMQSeries::Queue is a OO interface to the MQSeries Queue objects. | |
Download |
MQSeries::Queue Ranking & Summary
Advertisement
- License:
- Perl Artistic License
- Price:
- FREE
- Publisher Name:
- Morgan Stanley, Dean Witter and Co.
- Publisher web site:
- http://search.cpan.org/~hbiersma/MQSeries-1.25/MQSeries/Queue.pm
MQSeries::Queue Tags
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