Delicious Bookmark this on Delicious Share on Facebook SlashdotSlashdot It! Digg! Digg



PHP : Function Reference : SAM - Simple Asynchronous Messaging : SAMConnection->peekAll()

SAMConnection->peekAll()

Read one or more messages from a queue without removing it from the queue. ()

Example 2120. Retrieve all messages in a queue without removing them

<?php
$msgArray
= $conn->peekAll('queue://receive/test');
if (
$msgArray) {
  foreach (
$msgArray as $key => $msg) {
      echo
"Message $key: body = $msg->body\n";
  }
} else {
  echo
"PeekAll failed ($conn->errno) $conn->error";
}
?>

Example 2121.  Retrieve all messages from a queue with a matching correlation id

<?php

  $msgArray
= $conn->peekAll('queue://receive/test', array(SAM_CORRELID => $correlId ));
  if (
$msgArray) {

     foreach (
$msgArray as $key => $msg) {
           echo
"Message $key: body = $msg->body\n";
        }
     }
  else
     echo
"PeekAll failed ($conn->errno) $conn->error";
  }

?>

Change Language


Follow Navioo On Twitter
SAMConnection->commit()
SAMConnection->connect()
SAMConnection->__construct()
SAMConnection->disconnect()
SAMConnection->errno
SAMConnection->error
SAMConnection->isConnected()
SAMConnection->peek()
SAMConnection->peekAll()
SAMConnection->receive()
SAMConnection->remove()
SAMConnection->rollback()
SAMConnection->send()
SAMConnection::setDebug()
SAMConnection->subscribe()
SAMConnection->unsubscribe()
SAMMessage->body
SAMMessage->__construct()
SAMMessage->header
eXTReMe Tracker