diff --git a/Event/Queue/AmqpMessageQueue.php b/Event/Queue/AmqpMessageQueue.php index b480a53..99011f9 100644 --- a/Event/Queue/AmqpMessageQueue.php +++ b/Event/Queue/AmqpMessageQueue.php @@ -40,18 +40,18 @@ class AmqpMessageQueue implements MessageQueueInterface /** * @var boolean batchPublishing */ - private $batchPublishing; + protected $batchPublishing; /** * Make sure to initialize before we post our first message. * @var bool initialized */ - private $initialized = false; + protected $initialized = false; /** * @var array config */ - private $config; + protected $config; /** * @param array $config @@ -69,7 +69,7 @@ public function __construct(array $config) /** * Clean up after us */ - function __destruct() + public function __destruct() { if (!$this->initialized) { return; @@ -114,7 +114,7 @@ public function addMessage(QueueMessage $message, $delay = 0) * Create queue objects and init the class * @param array $config */ - private function init() + protected function init() { if ($this->initialized) { return;