diff --git a/src/Publisher/Publisher.php b/src/Publisher/Publisher.php index a8f0cca..d51d216 100644 --- a/src/Publisher/Publisher.php +++ b/src/Publisher/Publisher.php @@ -5,9 +5,9 @@ use Convenia\Pigeon\Drivers\DriverContract; use Illuminate\Foundation\Application; use Illuminate\Support\Arr; +use Illuminate\Support\Str; use PhpAmqpLib\Message\AMQPMessage; use PhpAmqpLib\Wire\AMQPTable; -use Illuminate\Support\Str; class Publisher implements PublisherContract { diff --git a/tests/Integration/Consumer/ConsumerTest.php b/tests/Integration/Consumer/ConsumerTest.php index af212e1..978730c 100644 --- a/tests/Integration/Consumer/ConsumerTest.php +++ b/tests/Integration/Consumer/ConsumerTest.php @@ -70,6 +70,7 @@ public function test_it_should_throw_timeout_with_multiple() /** * @requires extension pcntl + * * @ */ public function test_it_should_handle_sigterm_signal() diff --git a/tests/Integration/Publisher/PublisherTest.php b/tests/Integration/Publisher/PublisherTest.php index f3c768e..052ed7c 100644 --- a/tests/Integration/Publisher/PublisherTest.php +++ b/tests/Integration/Publisher/PublisherTest.php @@ -4,9 +4,9 @@ use Convenia\Pigeon\Drivers\Driver; use Convenia\Pigeon\Tests\Integration\TestCase; +use Illuminate\Support\Str; use PhpAmqpLib\Message\AMQPMessage; use PhpAmqpLib\Wire\AMQPTable; -use Illuminate\Support\Str; class PublisherTest extends TestCase { diff --git a/tests/Unit/DriverTest.php b/tests/Unit/DriverTest.php index 7b04297..6754fa1 100644 --- a/tests/Unit/DriverTest.php +++ b/tests/Unit/DriverTest.php @@ -145,7 +145,7 @@ function ($message, $exchange, $event) use ($key, $value, $event_name) { $app_headers = $message->get('application_headers'); return ($app_headers instanceof AMQPTable) - && (array_key_exists($key, $app_headers->getNativeData())) + && array_key_exists($key, $app_headers->getNativeData()) && ($app_headers->getNativeData()[$key] === $value) && ($event === $event_name) && ($exchange === Driver::EVENT_EXCHANGE); @@ -253,7 +253,6 @@ public function test_it_should_return_props_with_user_defined() public function test_it_should_return_props_without_dead_letter() { - // Setup $this->app['config']->set('pigeon.dead', null);