Check Stomp API result

Adam Roses Wight · ejegg · commit e35c23e087a0 · 2017-01-25T11:51:18.000-08:00
Tiny bit of error handling.

Bug: T109901
Change-Id: I64ca28b583ccd061cee9487eb706d72800a62d9f
diff --git a/src/PHPQueue/Backend/Stomp.php b/src/PHPQueue/Backend/Stomp.php
@@ -113,7 +113,10 @@ protected function readFrame($properties = null)
         if ($properties === null) {
             $properties = array('ack' => 'client');
         }
-        $this->getConnection()->subscribe($this->queue_name, $properties);
+        $result = $this->getConnection()->subscribe($this->queue_name, $properties);
+        if (!$result) {
+            throw new BackendException("No response when subscribing to queue {$this->queue_name}");
+        }
         if ($this->read_timeout) {
             $this->getConnection()->setReadTimeout($this->read_timeout);
         }

Original file line number	Diff line number	Diff line change
`@@ -113,7 +113,10 @@ protected function readFrame($properties = null)`
`113`	`113`	`if ($properties === null) {`
`114`	`114`	`$properties = array('ack' => 'client');`
`115`	`115`	`}`
`116`		`- $this->getConnection()->subscribe($this->queue_name, $properties);`
	`116`	`+ $result = $this->getConnection()->subscribe($this->queue_name, $properties);`
	`117`	`+ if (!$result) {`
	`118`	`+ throw new BackendException("No response when subscribing to queue {$this->queue_name}");`
	`119`	`+ }`
`117`	`120`	`if ($this->read_timeout) {`
`118`	`121`	`$this->getConnection()->setReadTimeout($this->read_timeout);`
`119`	`122`	`}`