diff --git a/pkg/wamp/LICENSE b/pkg/wamp/LICENSE index d9736f8bf..7afbaa1ff 100644 --- a/pkg/wamp/LICENSE +++ b/pkg/wamp/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 diff --git a/pkg/wamp/README.md b/pkg/wamp/README.md index 094a7ca94..6838a366c 100644 --- a/pkg/wamp/README.md +++ b/pkg/wamp/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) diff --git a/pkg/wamp/WampConsumer.php b/pkg/wamp/WampConsumer.php index c4859aa7d..a56058c91 100644 --- a/pkg/wamp/WampConsumer.php +++ b/pkg/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 diff --git a/pkg/wamp/composer.json b/pkg/wamp/composer.json index 77ef84e5b..edb1bcc86 100644 --- a/pkg/wamp/composer.json +++ b/pkg/wamp/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" },