Einführung

Beispiel der Verwendung

Das beiliegende Beispiel von Zend_Queue zeigt eine Vielzahl von Features, inklusive Erstellung der Queue, Empfangen der Queue, Empfangen von Nachrichten, Löschen von Nachrichten und Senden von Nachrichten.

  1. // Für Konfigurations Optionen siehe
  2. // @see Zend_Queue_Adapater::__construct()
  3. $options = array(
  4.     'name' => 'queue1',
  5. );
  6.  
  7. // Erstellung einer Array Queue
  8. $queue = new Zend_Queue('Array', $options);
  9.  
  10. // Eine Liste von Queues erhalten
  11. foreach ($queue->getQueues() as $name) {
  12.     echo $name, "\n";
  13. }
  14.  
  15. // eine neue Liste erstellen
  16. $queue2 = $queue->createQueue('queue2');
  17.  
  18. // Die Anzahl von Nachrichten in einer Queue erhalten
  19. // (unterstützt das Countable Interface von SPL)
  20. echo count($queue);
  21.  
  22. // Bis zu 5 Nachrichten von der Queue erhalten
  23. $messages = $queue->receive(5);
  24.  
  25. foreach ($messages as $i => $message) {
  26.     echo $message->body, "\n";
  27.  
  28.     // Wir haben die Nachrichten bearbeitet;
  29.     // jetzt löschen wir Sie von der Queue
  30.     $queue->deleteMessage($message);
  31. }
  32.  
  33. // Eine Nachricht zur aktuell aktiven Queue senden
  34. $queue->send('Meine Test Nachricht');
  35.  
  36. // Eine Queue die wir erstellt haben löschen inklusive aller Ihrer Nachrichten
  37. $queue->deleteQueue('queue2');

Einführung