diff --git a/modules/customModule/EventHandler.php b/modules/customModule/EventHandler.php
index 0ec6eb2..77be5b2 100644
--- a/modules/customModule/EventHandler.php
+++ b/modules/customModule/EventHandler.php
@@ -10,19 +10,11 @@ class EventHandler
 {
     public static function onServerInit(ServerEvent $event)
     {
-        echo 'Server initialized' . PHP_EOL;
+        $event->server->echo('Server initialized');
     }
 
     public static function onMessage(ConnectionMessageEvent $event)
     {
-        echo 'New message from ' . $event->connection->resourceId . ': ' . $event->message . PHP_EOL;
-
-        $event->server->sendAllUsers([
-            'message',
-            [
-                'from_id' => $event->connection->resourceId,
-                'text' => $event->message,
-            ],
-        ]);
+        $event->server->echo('New message from ' . $event->connection->resourceId . ': ' . $event->message);
     }
 }
diff --git a/modules/customModule/models/CustomItem.php b/modules/customModule/models/CustomItem.php
new file mode 100644
index 0000000..62a179f
--- /dev/null
+++ b/modules/customModule/models/CustomItem.php
@@ -0,0 +1,19 @@
+<?php
+
+namespace app\modules\customModule\models;
+
+use app\modules\customModule\models\query\CustomItemQuery;
+use app\modules\server\models\BaseItem;
+
+class CustomItem extends BaseItem
+{
+    const TYPE = 'custom';
+
+    /**
+     * @inheritdoc
+     */
+    public static function tableName()
+    {
+        return 'custom_item';
+    }
+}
diff --git a/modules/customModule/models/query/CustomItemQuery.php b/modules/customModule/models/query/CustomItemQuery.php
new file mode 100644
index 0000000..5659f1b
--- /dev/null
+++ b/modules/customModule/models/query/CustomItemQuery.php
@@ -0,0 +1,31 @@
+<?php
+
+namespace app\modules\customModule\models\query;
+
+use app\modules\customModule\models\CustomItem;
+use app\modules\server\models\query\BaseItemQuery;
+use yii\db\ActiveQuery;
+
+/**
+ * @see CustomItem
+ */
+class CustomItemQuery extends BaseItemQuery
+{
+    /**
+     * @inheritdoc
+     * @return CustomItem[]
+     */
+    public function all($db = null)
+    {
+        return parent::all($db);
+    }
+
+    /**
+     * @inheritdoc
+     * @return CustomItem|array|null
+     */
+    public function one($db = null)
+    {
+        return parent::one($db);
+    }
+}
diff --git a/modules/server/components/BaseServer.php b/modules/server/components/BaseServer.php
index c03c8c6..d1d6e65 100644
--- a/modules/server/components/BaseServer.php
+++ b/modules/server/components/BaseServer.php
@@ -26,4 +26,29 @@ abstract class BaseServer extends Component implements MessageComponentInterface
         Yii::$app->eventManager->trigger($name, $event);
     }
 
+    /**
+     * @param string $message
+     * @param bool $prependDate
+     * @param bool $appendEol
+     */
+    public function echo(string $message, $prependDate = true, $appendEol = true)
+    {
+        $result = '';
+
+        if ($prependDate) {
+            $ms = explode(' ', microtime());
+            $ms = round((float)$ms[0], 3) * 1000;
+
+            $result .= '[' . date('Y-m-d h:i:s', time()) . '.' . $ms . '] ';
+        }
+
+        $result .= $message;
+
+        if ($appendEol) {
+            $result .= PHP_EOL;
+        }
+
+        echo $result;
+    }
+
 }
diff --git a/modules/server/components/CoreServer.php b/modules/server/components/CoreServer.php
index 9754e14..d6d2a71 100644
--- a/modules/server/components/CoreServer.php
+++ b/modules/server/components/CoreServer.php
@@ -60,6 +60,7 @@ class CoreServer extends BaseServer
     public function onOpen(ConnectionInterface $connection)
     {
         if (!$this->authenticate($connection)) {
+            $connection->close();
             return;
         }
 
@@ -101,6 +102,8 @@ class CoreServer extends BaseServer
      */
     public function onError(ConnectionInterface $conn, \Exception $e)
     {
+        $conn->close();
+
         $this->trigger(self::EVENT_CONNECTION_ERROR, new ConnectionErrorEvent([
             'server' => $this,
             'connection' => $conn,
diff --git a/modules/server/interfaces/ItemInterface.php b/modules/server/interfaces/ItemInterface.php
new file mode 100644
index 0000000..07815bd
--- /dev/null
+++ b/modules/server/interfaces/ItemInterface.php
@@ -0,0 +1,17 @@
+<?php
+
+namespace app\modules\server\interfaces;
+
+use app\models\query\DeviceQuery;
+
+/**
+ * Interface ItemInterface
+ * @package app\modules\server\interfaces
+ */
+interface ItemInterface
+{
+    /**
+     * @return DeviceQuery
+     */
+    public function getDevice();
+}
diff --git a/modules/server/models/BaseItem.php b/modules/server/models/BaseItem.php
new file mode 100644
index 0000000..2a5f7e8
--- /dev/null
+++ b/modules/server/models/BaseItem.php
@@ -0,0 +1,76 @@
+<?php
+
+namespace app\modules\server\models;
+
+use app\models\Device;
+use yii\base\NotSupportedException;
+use yii\db\ActiveRecord;
+
+/**
+ * Class BaseItem
+ *
+ * @package app\modules\server\models
+ *
+ * @property integer $id
+ * @property integer $device_id
+ * @property string $type
+ * @property string $name
+ * @property string $title
+ *
+ * @property Device $device
+ */
+abstract class BaseItem extends ActiveRecord
+{
+    /**
+     * @inheritdoc
+     */
+    public static function tableName()
+    {
+        return 'item';
+    }
+
+    /**
+     * @return string
+     */
+    public static function getType()
+    {
+        return 'base';
+    }
+
+    /**
+     * @return \yii\db\ActiveQuery
+     */
+    public function getDevice()
+    {
+        return $this->hasOne(Device::className(), ['id' => 'device_id']);
+    }
+
+    /**
+     * @inheritdoc
+     */
+    public function init()
+    {
+        $this->type = static::getType();
+
+        parent::init();
+    }
+
+    /**
+     * @throws NotSupportedException
+     */
+    public static function find()
+    {
+        throw new NotSupportedException('Item query is not defined');
+    }
+
+    /**
+     * @inheritdoc
+     */
+    public function beforeSave($insert)
+    {
+        $this->type = static::getType();
+
+        return parent::beforeSave($insert);
+    }
+
+}
diff --git a/modules/server/models/query/BaseItemQuery.php b/modules/server/models/query/BaseItemQuery.php
new file mode 100644
index 0000000..33421e7
--- /dev/null
+++ b/modules/server/models/query/BaseItemQuery.php
@@ -0,0 +1,19 @@
+<?php
+
+namespace app\modules\server\models\query;
+
+use yii\db\ActiveQuery;
+
+abstract class BaseItemQuery extends ActiveQuery
+{
+    public $type;
+
+    public function prepare($builder)
+    {
+        if ($this->type !== null) {
+            $this->andWhere(['type' => $this->type]);
+        }
+
+        return parent::prepare($builder);
+    }
+}