fixes #1003

kalyabin · kalyabin · commit a626076755d6 · 2019-12-28T12:04:00.000+03:00
diff --git a/pkg/amqp-lib/AmqpContext.php b/pkg/amqp-lib/AmqpContext.php
@@ -172,7 +172,7 @@ public function declareQueue(InteropAmqpQueue $queue): int
             $queue->getArguments() ? new AMQPTable($queue->getArguments()) : null
         );
 
-        return $messageCount;
+        return $messageCount ?? 0;
     }
 
     public function deleteQueue(InteropAmqpQueue $queue): void

Original file line number	Diff line number	Diff line change
`@@ -172,7 +172,7 @@ public function declareQueue(InteropAmqpQueue $queue): int`
`172`	`172`	`$queue->getArguments() ? new AMQPTable($queue->getArguments()) : null`
`173`	`173`	`);`
`174`	`174`
`175`		`- return $messageCount;`
	`175`	`+ return $messageCount ?? 0;`
`176`	`176`	`}`
`177`	`177`
`178`	`178`	`public function deleteQueue(InteropAmqpQueue $queue): void`