Allow to merge with other configs

Author: microThread

src/CarrotMQ.php

@@ -36,6 +36,40 @@ public function __construct($config = [], LoggerInterface $logger = null)
         $this->logger->debug(\vsprintf('Instance of "%s" has been created', [self::class]));
     }
 
+    /**
+     * @return array
+     */
+    public function getConfig(): array
+    {
+        return $this->config;
+    }
+
+    /**
+     * @param array $config
+     *
+     * @return $this
+     */
+    public function setConfig(array $config): self
+    {
+        $this->config    = $config;
+        $this->container = null;
+
+        return $this;
+    }
+
+    /**
+     * @param array $config
+     *
+     * @return $this
+     */
+    public function mergeWithConfig(array $config): self
+    {
+        $this->config    = Config::create($this->config)->mergeWith($config)->toArray();
+        $this->container = null;
+
+        return $this;
+    }
+
     /**
      * @return Container
      */

src/Collection/BaseList.php

@@ -81,7 +81,7 @@ public function clear()
      */
     public function has($id)
     {
-        return \array_key_exists($id, $this->items);
+        return (isset($this->items[$id]) || \array_key_exists($id, $this->items));
     }
 
 }

src/Component.php

@@ -75,11 +75,27 @@ public function resetEvents()
      *
      * @return $this
      */
-    public function logger(LoggerInterface $logger)
+    public function setLogger(LoggerInterface $logger)
     {
         $this->logger = $logger;
 
         return $this;
     }
 
+    /**
+     * @return LoggerInterface|NullLogger
+     */
+    public function getLogger()
+    {
+        return $this->logger;
+    }
+
+    /**
+     * @return void
+     */
+    public function __destruct()
+    {
+        unset($this->id, $this->events, $this->logger);
+    }
+
 }

src/Connection.php

@@ -61,11 +61,11 @@ public function __destruct()
      *
      * @return $this
      */
-    public function logger(LoggerInterface $logger)
+    public function setLogger(LoggerInterface $logger)
     {
         $this->logger = $logger;
 
-        $this->driver->logger($this->logger);
+        $this->driver->setLogger($this->logger);
 
         return $this;
     }

src/Consumer.php

@@ -89,7 +89,7 @@ public function __construct(
                 $this->tag :
                 \vsprintf('[host: %s]-[pid: %s]-[queue: %s]', [\gethostname(), \getmypid(), $this->queue->name()]);
 
-        $this->queue->logger($this->logger);
+        $this->queue->setLogger($this->logger);
     }
 
     /**
@@ -140,7 +140,7 @@ protected function prepare()
             }
 
             /* @var Extension $extension */
-            $extension->logger($this->logger);
+            $extension->setLogger($this->logger);
 
             $this->events->addSubscriber($extension);
         }
@@ -151,7 +151,7 @@ protected function prepare()
         |--------------------------------------------------------------------------
         |
         */
-        $this->queue->logger($this->logger);
+        $this->queue->setLogger($this->logger);
 
         if ($this->queue->canAutoCreate()) {
             $this->queue->install();

src/Container.php

@@ -112,7 +112,7 @@ public function logger(LoggerInterface $logger)
             /* @var BaseList $context */
             foreach ($this->{$context}->all() as $entry) {
                 /* @var Component $entry */
-                $entry->logger($logger);
+                $entry->setLogger($logger);
             }
         }
 

src/Publisher.php

@@ -60,7 +60,7 @@ public function __construct(
         $this->topic     = $topic;
         $this->config    = Config::create(static::DEFAULTS)->mergeWith($config)->toArray();
 
-        $this->topic->logger($this->logger);
+        $this->topic->setLogger($this->logger);
 
         $context = $this->topic->connection()->context(true);