uncomment exception.

Author: makasim

Queue/PopulateProcessor.php

@@ -51,7 +51,7 @@ public function process(PsrMessage $message, PsrContext $context)
 
         $objectsCount = 0;
 
-//        try {
+        try {
             $data = JSON::decode($message->getBody());
 
             if (!isset($data['options'])) {
@@ -82,9 +82,9 @@ public function process(PsrMessage $message, PsrContext $context)
             $pagerPersister->insert($pager, $options);
 
             return Result::reply($this->createReplyMessage($context, $message, $objectsCount));
-//        } catch (\Throwable $e) {
-//            return Result::reply($this->createExceptionReplyMessage($context, $message, $objectsCount, $e), Result::REJECT);
-//        }
+        } catch (\Throwable $e) {
+            return Result::reply($this->createExceptionReplyMessage($context, $message, $objectsCount, $e), Result::REJECT);
+        }
     }
 
     /**