src/AckResolver.php
<?php
namespace React\Stomp;
use React\Stomp\Client;
class AckResolver
{
private $result;
private $client;
private $subscriptionId;
private $messageId;
public function __construct(Client $client, $subscriptionId, $messageId)
{
$this->client = $client;
$this->subscriptionId = $subscriptionId;
$this->messageId = $messageId;
}
public function ack(array $headers = array())
{
$this->throwExceptionIfResolved();
$this->result = true;
$this->client->ack($this->subscriptionId, $this->messageId, $headers);
}
public function nack(array $headers = array())
{
$this->throwExceptionIfResolved();
$this->result = false;
$this->client->nack($this->subscriptionId, $this->messageId, $headers);
}
private function throwExceptionIfResolved()
{
if (null !== $this->result) {
throw new \RuntimeException('You must not try to resolve an acknowledgement more than once.');
}
}
}