<!-- Collection of code snippets by Arne Vajhøj -->
<!-- (from articles on eksperten.dk / vajhoej.dk written sometime between 2004 and now) -->
<?php

require 'MQ.php';

class Good extends MQ {
	public function getConnection() {
		return new Stomp('tcp://localhost:61613');
	}
	public function test() {
		for($i = 0; $i < 10; $i++) {
			$con = $this->getConnection();
			$con->subscribe('NonXAin');
			$frame = $con->readFrame();
			$msg = $frame->body;
			$con->ack($frame);
			$con->unsubscribe('NonXAin');
			$con2 = $this->getConnection();
			$con2->send('NonXAout', $msg);
			unset($con);
			unset($con2);
		}
	}
}

MQ::demo(new Good());

?>