diff --git a/composer.lock b/composer.lock
index 669368d..be9c271 100644
--- a/composer.lock
+++ b/composer.lock
@@ -596,23 +596,23 @@
         },
         {
             "name": "amphp/http-server",
-            "version": "v2.0.0-rc4",
+            "version": "v2.0.0",
             "source": {
                 "type": "git",
                 "url": "https://github.com/amphp/http-server.git",
-                "reference": "2c3d5724b4b86f9a7fa7feed13a7c50e2bf8ad1b"
+                "reference": "5e75761240e33cc7c6ac9eff303aaf87df9125d9"
             },
             "dist": {
                 "type": "zip",
-                "url": "https://api.github.com/repos/amphp/http-server/zipball/2c3d5724b4b86f9a7fa7feed13a7c50e2bf8ad1b",
-                "reference": "2c3d5724b4b86f9a7fa7feed13a7c50e2bf8ad1b",
+                "url": "https://api.github.com/repos/amphp/http-server/zipball/5e75761240e33cc7c6ac9eff303aaf87df9125d9",
+                "reference": "5e75761240e33cc7c6ac9eff303aaf87df9125d9",
                 "shasum": ""
             },
             "require": {
                 "amphp/amp": "^2",
                 "amphp/byte-stream": "^1.3",
                 "amphp/hpack": "^3",
-                "amphp/http": "^1.6-rc1",
+                "amphp/http": "^1.6",
                 "amphp/socket": "^1",
                 "cash/lrucache": "^1",
                 "league/uri": "^6",
@@ -674,7 +674,7 @@
                 "non-blocking",
                 "server"
             ],
-            "time": "2020-01-04T18:10:10+00:00"
+            "time": "2020-02-18T15:52:29+00:00"
         },
         {
             "name": "amphp/http-server-form-parser",
@@ -809,29 +809,30 @@
         },
         {
             "name": "amphp/parallel",
-            "version": "v1.2.0",
+            "version": "v1.3.0",
             "source": {
                 "type": "git",
                 "url": "https://github.com/amphp/parallel.git",
-                "reference": "53aa422eaf89a539b4df58284f7bdf5219e37f66"
+                "reference": "346d3f50939d3533a49ef161a0b9c8cca6eee809"
             },
             "dist": {
                 "type": "zip",
-                "url": "https://api.github.com/repos/amphp/parallel/zipball/53aa422eaf89a539b4df58284f7bdf5219e37f66",
-                "reference": "53aa422eaf89a539b4df58284f7bdf5219e37f66",
+                "url": "https://api.github.com/repos/amphp/parallel/zipball/346d3f50939d3533a49ef161a0b9c8cca6eee809",
+                "reference": "346d3f50939d3533a49ef161a0b9c8cca6eee809",
                 "shasum": ""
             },
             "require": {
                 "amphp/amp": "^2",
-                "amphp/byte-stream": "^1.5",
+                "amphp/byte-stream": "^1.6.1",
                 "amphp/parser": "^1",
                 "amphp/process": "^1",
-                "amphp/sync": "^1.0.1"
+                "amphp/sync": "^1.0.1",
+                "php": ">=7.1"
             },
             "require-dev": {
                 "amphp/php-cs-fixer-config": "dev-master",
-                "amphp/phpunit-util": "^1",
-                "phpunit/phpunit": "^6"
+                "amphp/phpunit-util": "^1.1",
+                "phpunit/phpunit": "^8 || ^7"
             },
             "type": "library",
             "autoload": {
@@ -839,6 +840,8 @@
                     "Amp\\Parallel\\": "lib"
                 },
                 "files": [
+                    "lib/Context/functions.php",
+                    "lib/Sync/functions.php",
                     "lib/Worker/functions.php"
                 ]
             },
@@ -847,13 +850,13 @@
                 "MIT"
             ],
             "authors": [
-                {
-                    "name": "Stephen Coakley",
-                    "email": "me@stephencoakley.com"
-                },
                 {
                     "name": "Aaron Piotrowski",
                     "email": "aaron@trowski.com"
+                },
+                {
+                    "name": "Stephen Coakley",
+                    "email": "me@stephencoakley.com"
                 }
             ],
             "description": "Parallel processing component for Amp.",
@@ -865,7 +868,7 @@
                 "multi-processing",
                 "multi-threading"
             ],
-            "time": "2019-05-11T17:13:47+00:00"
+            "time": "2020-02-23T15:28:43+00:00"
         },
         {
             "name": "amphp/parser",
@@ -1283,16 +1286,16 @@
         },
         {
             "name": "amphp/websocket-server",
-            "version": "v2.0.0-rc1",
+            "version": "v2.0.0-rc2",
             "source": {
                 "type": "git",
                 "url": "https://github.com/amphp/websocket-server.git",
-                "reference": "8c723e902a56a41eefbf30d7ee1475755743daa2"
+                "reference": "84b4923c64a2e1f9707ee712192e62b30d448d31"
             },
             "dist": {
                 "type": "zip",
-                "url": "https://api.github.com/repos/amphp/websocket-server/zipball/8c723e902a56a41eefbf30d7ee1475755743daa2",
-                "reference": "8c723e902a56a41eefbf30d7ee1475755743daa2",
+                "url": "https://api.github.com/repos/amphp/websocket-server/zipball/84b4923c64a2e1f9707ee712192e62b30d448d31",
+                "reference": "84b4923c64a2e1f9707ee712192e62b30d448d31",
                 "shasum": ""
             },
             "require": {
@@ -1302,7 +1305,7 @@
                 "amphp/http-server": "^2",
                 "amphp/socket": "^1",
                 "amphp/websocket": "^1",
-                "php": ">=7.1"
+                "php": ">=7.2"
             },
             "require-dev": {
                 "amphp/http-client": "^4",
@@ -1310,11 +1313,9 @@
                 "amphp/http-server-static-content": "^1.0.4",
                 "amphp/log": "^1",
                 "amphp/php-cs-fixer-config": "dev-master",
-                "amphp/phpunit-util": "^1.1",
-                "infection/infection": "^0.9.3",
+                "amphp/phpunit-util": "^1.3",
                 "league/climate": "^3",
-                "league/uri-schemes": "^1.1",
-                "phpunit/phpunit": "^8 || ^7"
+                "phpunit/phpunit": "^9 || ^8 || ^7"
             },
             "suggest": {
                 "ext-zlib": "Required for compression"
@@ -1353,7 +1354,7 @@
                 "server",
                 "websocket"
             ],
-            "time": "2019-08-21T17:09:20+00:00"
+            "time": "2020-02-22T05:38:29+00:00"
         },
         {
             "name": "amphp/windows-registry",
@@ -1581,12 +1582,12 @@
             "source": {
                 "type": "git",
                 "url": "https://github.com/danog/MadelineProto.git",
-                "reference": "ebd4245d9dca70ce9fbddb46ae8f749b189bd871"
+                "reference": "82599e686ebc1ab253089b3015b94143c9313853"
             },
             "dist": {
                 "type": "zip",
-                "url": "https://api.github.com/repos/danog/MadelineProto/zipball/ebd4245d9dca70ce9fbddb46ae8f749b189bd871",
-                "reference": "ebd4245d9dca70ce9fbddb46ae8f749b189bd871",
+                "url": "https://api.github.com/repos/danog/MadelineProto/zipball/82599e686ebc1ab253089b3015b94143c9313853",
+                "reference": "82599e686ebc1ab253089b3015b94143c9313853",
                 "shasum": ""
             },
             "require": {
@@ -1673,7 +1674,7 @@
                 "telegram",
                 "video"
             ],
-            "time": "2020-02-15T21:03:41+00:00"
+            "time": "2020-02-23T18:30:11+00:00"
         },
         {
             "name": "danog/magicalserializer",
@@ -2672,12 +2673,12 @@
             "source": {
                 "type": "git",
                 "url": "https://github.com/Roave/SecurityAdvisories.git",
-                "reference": "0365bf26eddd4a8be9980d7dabf05ceb2aba2f02"
+                "reference": "1df6b9d09d2b074fd3f0f10a7696d9f797d4772c"
             },
             "dist": {
                 "type": "zip",
-                "url": "https://api.github.com/repos/Roave/SecurityAdvisories/zipball/0365bf26eddd4a8be9980d7dabf05ceb2aba2f02",
-                "reference": "0365bf26eddd4a8be9980d7dabf05ceb2aba2f02",
+                "url": "https://api.github.com/repos/Roave/SecurityAdvisories/zipball/1df6b9d09d2b074fd3f0f10a7696d9f797d4772c",
+                "reference": "1df6b9d09d2b074fd3f0f10a7696d9f797d4772c",
                 "shasum": ""
             },
             "conflict": {
@@ -2696,6 +2697,7 @@
                 "cakephp/cakephp": ">=1.3,<1.3.18|>=2,<2.4.99|>=2.5,<2.5.99|>=2.6,<2.6.12|>=2.7,<2.7.6|>=3,<3.5.18|>=3.6,<3.6.15|>=3.7,<3.7.7",
                 "cart2quote/module-quotation": ">=4.1.6,<=4.4.5|>=5,<5.4.4",
                 "cartalyst/sentry": "<=2.1.6",
+                "centreon/centreon": "<18.10.8|>=19,<19.4.5",
                 "cesnet/simplesamlphp-module-proxystatistics": "<3.1",
                 "codeigniter/framework": "<=3.0.6",
                 "composer/composer": "<=1-alpha.11",
@@ -2762,7 +2764,7 @@
                 "monolog/monolog": ">=1.8,<1.12",
                 "namshi/jose": "<2.2",
                 "onelogin/php-saml": "<2.10.4",
-                "oneup/uploader-bundle": ">=1,<1.9.3|>=2,<2.1.5",
+                "oneup/uploader-bundle": "<1.9.3|>=2,<2.1.5",
                 "openid/php-openid": "<2.3",
                 "oro/crm": ">=1.7,<1.7.4",
                 "oro/platform": ">=1.7,<1.7.4",
@@ -2798,7 +2800,7 @@
                 "silverstripe/cms": "<4.3.6|>=4.4,<4.4.4",
                 "silverstripe/comments": ">=1.3,<1.9.99|>=2,<2.9.99|>=3,<3.1.1",
                 "silverstripe/forum": "<=0.6.1|>=0.7,<=0.7.3",
-                "silverstripe/framework": "<4.4.4",
+                "silverstripe/framework": "<4.4.5|>=4.5,<4.5.2",
                 "silverstripe/graphql": ">=2,<2.0.5|>=3,<3.1.2",
                 "silverstripe/registry": ">=2.1,<2.1.2|>=2.2,<2.2.1",
                 "silverstripe/restfulserver": ">=1,<1.0.9|>=2,<2.0.4",
@@ -2922,7 +2924,7 @@
                 }
             ],
             "description": "Prevents installation of composer packages with known security vulnerabilities: no API, simply require it",
-            "time": "2020-02-10T16:13:40+00:00"
+            "time": "2020-02-19T06:23:50+00:00"
         }
     ],
     "aliases": [],
diff --git a/src/Controllers/EventsController.php b/src/Controllers/EventsController.php
index a0bd248..56567c1 100644
--- a/src/Controllers/EventsController.php
+++ b/src/Controllers/EventsController.php
@@ -7,23 +7,37 @@ use Amp\Http\Server\Response;
 use Amp\Http\Server\Router;
 use Amp\Promise;
 use Amp\Success;
+use Amp\Websocket\Server\ClientHandler;
 use Amp\Websocket\Server\Websocket;
 use TelegramApiServer\Client;
 use TelegramApiServer\EventObservers\EventObserver;
 use function Amp\call;
 
-class EventsController extends Websocket
+class EventsController implements ClientHandler
 {
     private Client $client;
+    private ?Websocket $endpoint;
 
-    public static function getRouterCallback(Client $client): EventsController
+    public static function getRouterCallback(Client $client): Websocket
     {
         $class = new static();
         $class->client = $client;
-        return $class;
+        return  new Websocket($class);
     }
 
-    public function onHandshake(Request $request, Response $response): Promise
+    public function onStart(Websocket $endpoint): Promise
+    {
+        $this->endpoint = $endpoint;
+        return new Success;
+    }
+
+    public function onStop(Websocket $endpoint): Promise
+    {
+        $this->endpoint = null;
+        return new Success;
+    }
+
+    public function handleHandshake(Request $request, Response $response): Promise
     {
         try {
             $session = $request->getAttribute(Router::class)['session'] ?? null;
@@ -37,7 +51,7 @@ class EventsController extends Websocket
         return new Success($response);
     }
 
-    public function onConnect(\Amp\Websocket\Client $client, Request $request, Response $response): Promise
+    public function handleClient(\Amp\Websocket\Client $client, Request $request, Response $response): Promise
     {
         return call(function() use($client, $request) {
             $requestedSession = $request->getAttribute(Router::class)['session'] ?? null;
@@ -71,7 +85,7 @@ class EventsController extends Websocket
                 'id' => null,
             ];
 
-            $this->multicast(
+            $this->endpoint->multicast(
                 json_encode(
                     $update,
                     JSON_THROW_ON_ERROR |
diff --git a/src/Controllers/LogController.php b/src/Controllers/LogController.php
index e58e28f..03fc326 100644
--- a/src/Controllers/LogController.php
+++ b/src/Controllers/LogController.php
@@ -7,20 +7,35 @@ use Amp\Http\Server\Response;
 use Amp\Http\Server\Router;
 use Amp\Promise;
 use Amp\Success;
+use Amp\Websocket\Server\ClientHandler;
 use Amp\Websocket\Server\Websocket;
 use Psr\Log\LogLevel;
 use TelegramApiServer\EventObservers\LogObserver;
 use TelegramApiServer\Logger;
 use function Amp\call;
 
-class LogController extends Websocket
+class LogController implements ClientHandler
 {
-    public static function getRouterCallback(): LogController
+    private ?Websocket $endpoint;
+
+    public static function getRouterCallback(): Websocket
     {
-        return new static();
+        return new Websocket(new static());
     }
 
-    public function onHandshake(Request $request, Response $response): Promise
+    public function onStart(Websocket $endpoint): Promise
+    {
+        $this->endpoint = $endpoint;
+        return new Success;
+    }
+
+    public function onStop(Websocket $endpoint): Promise
+    {
+        $this->endpoint = null;
+        return new Success;
+    }
+
+    public function handleHandshake(Request $request, Response $response): Promise
     {
         $level = $request->getAttribute(Router::class)['level'] ?? LogLevel::DEBUG;
         if (!isset(Logger::$levels[$level])) {
@@ -29,7 +44,7 @@ class LogController extends Websocket
         return new Success($response);
     }
 
-    public function onConnect(\Amp\Websocket\Client $client, Request $request, Response $response): Promise
+    public function handleClient(\Amp\Websocket\Client $client, Request $request, Response $response): Promise
     {
         return call(function() use($client, $request) {
             $level = $request->getAttribute(Router::class)['level'] ?? LogLevel::DEBUG;
@@ -64,7 +79,7 @@ class LogController extends Websocket
                 'id' => null,
             ];
 
-            $this->multicast(
+            $this->endpoint->multicast(
                 json_encode(
                     $update,
                     JSON_THROW_ON_ERROR |