<!-- 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 Bad extends MQ {
	public function getConnection() {
		return new Stomp('tcp://localhost:61613');
	}
	public function test() {
		for($i = 0; $i < 10; $i++) {
			try {
				$con = $this->getConnection();
				$con->subscribe('NonXAin');
				$frame = $con->readFrame();
				$msg = $frame->body;
				$con->ack($frame);
				$con->unsubscribe('NonXAin');
				if($i % 2 != 0) throw new Problem();
				$con2 = $this->getConnection();
				$con2->send('NonXAout', $msg);
				unset($con);
				unset($con2);
			} catch(Problem $ex) {
				echo "Problem\r\n";
			}
		}
	}
}

MQ::demo(new Bad());

?>