Merge pull request #6 from wlogic/feature/fr-3

Updated return
wlogic · Apr 29, 2020 · 2712237 · 2712237
2 parents 5544340 + 7146762
commit 2712237
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/Command/GoBatchConsumerCommand.php b/Command/GoBatchConsumerCommand.php
@@ -61,7 +61,7 @@ protected function execute(InputInterface $input, OutputInterface $output)
         // store response
         file_put_contents($input->getArgument('filename')."_response", json_encode($response));
         // go application is expecting an exit code
-        exit(0);
+        return 0;
     }
 
     protected function getConsumerService()

diff --git a/Command/GoConsumerCommand.php b/Command/GoConsumerCommand.php
@@ -41,7 +41,7 @@ protected function execute(InputInterface $input, OutputInterface $output)
         $response = call_user_func([$this->getContainer()->get($class), $method,], $msg);
 
         // go application is expecting an exit code that is translated into ack / nack
-        exit($this->processResponse($response));
+        return $this->processResponse($response);
     }
 
     protected function getConsumerService()

diff --git a/RabbitMq/BatchConsumer.php b/RabbitMq/BatchConsumer.php
@@ -55,7 +55,7 @@ class BatchConsumer extends BaseAmqp implements DequeuerInterface
     /**
      * @var int number of seconds before graceful exit
      */
-    protected $gracefulMaxExecutionSeconds;
+    protected $gracefulMaxExecutionSeconds = 0;
     /**
      * @var bool
      */