reader example

Author: ikilobyte

examples/reader.php

@@ -0,0 +1,43 @@
+<?php
+
+
+use Pulsar\Message;
+use Pulsar\Reader;
+use Pulsar\ReaderOptions;
+
+require_once __DIR__ . '/../vendor/autoload.php';
+
+
+$options = new ReaderOptions();
+
+// If permission authentication is available
+// Only JWT authentication is currently supported
+// $options->setAuthentication(new Jwt('token'));
+
+$options->setConnectTimeout(3);
+$options->setTopic('persistent://public/default/demo'); // support partition topic
+
+// Read the latest message
+$options->setStartMessageID(Message::latestMessageIdData());
+
+// From the earliest message
+// $options->setStartMessageID(Message::earliestMessageIdData());
+
+// Start reading from a message
+// $options->setStartMessageID(Message::deserialize('621:103:0'));
+
+$reader = new Reader('pulsar://localhost:6650', $options);
+$reader->connect();
+
+while (true) {
+    $message = $reader->next();
+    echo sprintf('Got message 【%s】messageID[%s]  topic[%s] publishTime[%s]',
+            $message->getPayload(),
+            $message->getMessageId(),
+            $message->getTopic(),
+            $message->getPublishTime()
+        ) . "\n";
+
+}
+
+$reader->close();