develop

turboboy88 · turboboy88 · commit 9cbbce8167bf · 2018-05-02T12:11:38.000+03:00
diff --git a/pkg/mongodb/MongodbMessage.php b/pkg/mongodb/MongodbMessage.php
@@ -66,8 +66,6 @@ public function __construct($body = '', array $properties = [], array $headers =
         $this->properties = $properties;
         $this->headers = $headers;
         $this->redelivered = false;
-        $this->priority = 0;
-        $this->deliveryDelay = null;
     }
 
     /**
diff --git a/pkg/mongodb/MongodbProducer.php b/pkg/mongodb/MongodbProducer.php
@@ -52,7 +52,7 @@ public function send(PsrDestination $destination, PsrMessage $message)
         InvalidDestinationException::assertDestinationInstanceOf($destination, MongodbDestination::class);
         InvalidMessageException::assertMessageInstanceOf($message, MongodbMessage::class);
 
-        if (null !== $this->priority && 0 === $message->getPriority()) {
+        if (null !== $this->priority && null === $message->getPriority()) {
             $message->setPriority($this->priority);
         }
         if (null !== $this->deliveryDelay && null === $message->getDeliveryDelay()) {

Original file line number	Diff line number	Diff line change
`@@ -66,8 +66,6 @@ public function __construct($body = '', array $properties = [], array $headers =`
`66`	`66`	`$this->properties = $properties;`
`67`	`67`	`$this->headers = $headers;`
`68`	`68`	`$this->redelivered = false;`
`69`		`- $this->priority = 0;`
`70`		`- $this->deliveryDelay = null;`
`71`	`69`	`}`
`72`	`70`
`73`	`71`	`/**`
Original file line number	Diff line number	Diff line change
`@@ -52,7 +52,7 @@ public function send(PsrDestination $destination, PsrMessage $message)`
`52`	`52`	`InvalidDestinationException::assertDestinationInstanceOf($destination, MongodbDestination::class);`
`53`	`53`	`InvalidMessageException::assertMessageInstanceOf($message, MongodbMessage::class);`
`54`	`54`
`55`		`- if (null !== $this->priority && 0 === $message->getPriority()) {`
	`55`	`+ if (null !== $this->priority && null === $message->getPriority()) {`
`56`	`56`	`$message->setPriority($this->priority);`
`57`	`57`	`}`
`58`	`58`	`if (null !== $this->deliveryDelay && null === $message->getDeliveryDelay()) {`