wamp

Author: ASKozienko

LICENSE

@@ -1,5 +1,5 @@
 The MIT License (MIT)
-Copyright (c) 2017 Kotliar Maksym
+Copyright (c) 2018 Forma-Pro
 
 Permission is hereby granted, free of charge, to any person obtaining a copy
 of this software and associated documentation files (the "Software"), to deal

README.md

@@ -1,4 +1,4 @@
-# Web Application Messaging Protocol Transport
+# Web Application Messaging Protocol (WAMP) Transport
 
 [![Gitter](https://badges.gitter.im/php-enqueue/Lobby.svg)](https://gitter.im/php-enqueue/Lobby)
 [![Build Status](https://travis-ci.org/php-enqueue/wamp.png?branch=master)](https://travis-ci.org/php-enqueue/wamp)

WampConsumer.php

@@ -99,7 +99,12 @@ public function receive(int $timeout = 0): ?Message
 
         $this->client->getLoop()->run();
 
-        return $this->message ?: null;
+        $message = $this->message;
+
+        $this->timer = null;
+        $this->message = null;
+
+        return $message;
     }
 
     public function receiveNoWait(): ?Message

composer.json

@@ -8,6 +8,7 @@
     "require": {
         "php": "^7.1.3",
         "queue-interop/queue-interop": "0.7.x-dev",
+        "enqueue/dsn": "0.9.x-dev",
         "thruway/pawl-transport": "^0.5.0",
         "voryx/thruway": "^0.5.3"
     },