tests/smoke/recv.php

#!/usr/bin/env php
<?php

include("proton.php");

$messenger = new Messenger();
$messenger->incoming_window = 10;
$message = new Message();

$address = $argv[1];
if (!$address) {
  $address = "~0.0.0.0";
}
$messenger->subscribe($address);

$messenger->start();

while (true) {
  $messenger->recv();
  $messenger->get($message);
  print "Got: $message\n";
  $messenger->accept();
}

$messenger->stop();

?>