diff --git a/src/StompQueue.php b/src/StompQueue.php index 015a7cf..4ed0763 100755 --- a/src/StompQueue.php +++ b/src/StompQueue.php @@ -81,13 +81,13 @@ public function push($job, $data = '', $queue = null) * * @param string $payload * @param string $queue - * @param array $options + * @param array $headers * @return mixed */ - public function pushRaw($payload, $queue = null, array $options = []) + public function pushRaw($payload, $queue = null, array $headers = []) { - $message = new Message($payload); - $this->getStomp()->send($this->getQueue($queue), $message, $options); + $message = new Message($payload, $headers); + $this->getStomp()->send($this->getQueue($queue), $message); } /**