Skip to content

Commit 8b8cce9

Browse files
committed
Use namespace
1 parent c42e720 commit 8b8cce9

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

Diff for: src/Queue.php

+3-2
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55
use Illuminate\Contracts\Queue\Queue as QueueContract;
66
use Illuminate\Queue\Queue as BaseQueue;
77
use Interop\Queue\PsrContext;
8+
use Interop\Amqp\Impl\AmqpMessage;
89

910
class Queue extends BaseQueue implements QueueContract
1011
{
@@ -58,7 +59,7 @@ public function pushRaw($payload, $queue = null, array $options = [])
5859
{
5960
$message = $this->psrContext->createMessage($payload);
6061

61-
if ($message instanceof \Interop\Amqp\Impl\AmqpMessage) {
62+
if ($message instanceof AmqpMessage) {
6263
$message->setDeliveryMode(\Interop\Amqp\AmqpMessage::DELIVERY_MODE_PERSISTENT);
6364
}
6465

@@ -75,7 +76,7 @@ public function later($delay, $job, $data = '', $queue = null)
7576
{
7677
$message = $this->psrContext->createMessage($this->createPayload($job, $data));
7778

78-
if ($message instanceof \Interop\Amqp\Impl\AmqpMessage) {
79+
if ($message instanceof AmqpMessage) {
7980
$message->setDeliveryMode(\Interop\Amqp\AmqpMessage::DELIVERY_MODE_PERSISTENT);
8081
}
8182

0 commit comments

Comments
 (0)