Support lazy connections in publisher (Fixes #171)

paulkamer · paulkamer · commit 2a2917d4b8e9 · 2014-03-11T19:54:29.000+01:00
diff --git a/RabbitMq/Producer.php b/RabbitMq/Producer.php
@@ -46,6 +46,6 @@ public function publish($msgBody, $routingKey = '', $additionalProperties = arra
         }
 
         $msg = new AMQPMessage((string) $msgBody, array_merge($this->getBasicProperties(), $additionalProperties));
-        $this->ch->basic_publish($msg, $this->exchangeOptions['name'], (string) $routingKey);
+        $this->getChannel()->basic_publish($msg, $this->exchangeOptions['name'], (string) $routingKey);
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -46,6 +46,6 @@ public function publish($msgBody, $routingKey = '', $additionalProperties = arra`
`46`	`46`	`}`
`47`	`47`
`48`	`48`	`$msg = new AMQPMessage((string) $msgBody, array_merge($this->getBasicProperties(), $additionalProperties));`
`49`		`- $this->ch->basic_publish($msg, $this->exchangeOptions['name'], (string) $routingKey);`
	`49`	`+ $this->getChannel()->basic_publish($msg, $this->exchangeOptions['name'], (string) $routingKey);`
`50`	`50`	`}`
`51`	`51`	`}`