spiral / framework

src/Queue/tests/Interceptor/Consume/RetryPolicyInterceptorTest.php

Spacing +13 added lines, -13 removed lines

@@ -80,9 +80,9 @@ 
             ->with(self::class, 'bar', [])
             ->willThrowException(new TestRetryException());
 
-        try {
+        try{
             $this->interceptor->process(self::class, 'bar', [], $this->core);
-        } catch (RetryException $e) {
+        }catch (RetryException $e){
             $this->assertSame(1, $e->getOptions()->getDelay());
             $this->assertSame(['attempts' => ['1']], $e->getOptions()->getHeaders());
         }
@@ -100,9 +100,9 @@ 
                 retryPolicy: new \Spiral\Queue\RetryPolicy(maxAttempts: 2, delay: 4)
             ));
 
-        try {
+        try{
             $this->interceptor->process(self::class, 'bar', [], $this->core);
-        } catch (RetryException $e) {
+        }catch (RetryException $e){
             $this->assertSame(4, $e->getOptions()->getDelay());
             $this->assertSame(['attempts' => ['1']], $e->getOptions()->getHeaders());
         }
@@ -120,14 +120,14 @@ 
             ->with(self::class, 'bar', ['headers' => ['attempts' => ['1']]])
             ->willThrowException(new TestRetryException());
 
-        try {
+        try{
             $this->interceptor->process(
                 self::class,
                 'bar',
                 ['headers' => ['attempts' => ['1']]],
                 $this->core
             );
-        } catch (RetryException $e) {
+        }catch (RetryException $e){
             $this->assertSame(8, $e->getOptions()->getDelay());
             $this->assertSame(['attempts' => ['2']], $e->getOptions()->getHeaders());
         }
@@ -147,14 +147,14 @@ 
                 retryPolicy: new \Spiral\Queue\RetryPolicy(maxAttempts: 3, delay: 4, multiplier: 2)
             ));
 
-        try {
+        try{
             $this->interceptor->process(
                 self::class,
                 'bar',
                 ['headers' => ['attempts' => ['1']]],
                 $this->core
             );
-        } catch (RetryException $e) {
+        }catch (RetryException $e){
             $this->assertSame(8, $e->getOptions()->getDelay());
             $this->assertSame(['attempts' => ['2']], $e->getOptions()->getHeaders());
         }
@@ -171,7 +171,7 @@ 
             ->method('callAction')
             ->with(self::class, 'bar', ['headers' => ['attempts' => ['1']]])
             ->willThrowException(new TestRetryException(
-                retryPolicy: new class implements RetryPolicyInterface {
+                retryPolicy: new class implements RetryPolicyInterface{
                     public function isRetryable(\Throwable $exception, int $attempts = 0): bool
                     {
                         return true;
@@ -184,14 +184,14 @@ 
                 }
             ));
 
-        try {
+        try{
             $this->interceptor->process(
                 self::class,
                 'bar',
                 ['headers' => ['attempts' => ['1']]],
                 $this->core
             );
-        } catch (RetryException $e) {
+        }catch (RetryException $e){
             $this->assertSame(5, $e->getOptions()->getDelay());
             $this->assertSame(['attempts' => ['2']], $e->getOptions()->getHeaders());
         }
@@ -213,14 +213,14 @@ 
                 )
             ));
 
-        try {
+        try{
             $this->interceptor->process(
                 self::class,
                 'bar',
                 ['headers' => ['attempts' => ['1']]],
                 $this->core
             );
-        } catch (RetryException $e) {
+        }catch (RetryException $e){
             $this->assertSame(8, $e->getOptions()->getDelay());
             $this->assertSame(['attempts' => ['2']], $e->getOptions()->getHeaders());
         }