Restitution batch processing

bundle/medona/Controller/ArchiveRestitutionRequest.php

@@ -322,6 +322,30 @@ class ArchiveRestitutionRequest extends abstractMessage
         return $replyMessage;
     }
 
+    /**
+     * Process the messages
+     *
+     * @return medona/message $message
+     */
+    public function processBatch()
+    {
+        $results = array();
+
+        $messages = $this->sdoFactory->find("medona/message", "status='accepted' AND type='ArchiveRestitutionRequest' AND active=true");
+        foreach ($messages as $message) {
+            $this->changeStatus($message->messageId, "processing");
+            $this->loadData($message);
+
+            try {
+                $results[(string) $message->messageId] = $this->process($message);
+            } catch (\Exception $e) {
+                $results[(string) $message->messageId] = $e;
+            }
+        }
+
+        return $results;
+    }
+
     /**
      * Validate message against schema and rules
      * @param medona/message $message

bundle/medona/archiveRestitutionInterface.php

@@ -151,6 +151,14 @@ interface archiveRestitutionInterface extends messageInterface
      */
     public function updateProcess_message_();
 
+
+    /**
+     * Processes messages 
+     *
+     * @action medona/ArchiveRestitutionRequest/processBatch
+     */
+    public function updateProcessBatch();
+
     /**
      * Flag archives for restitution
      * @param array  $archiveIds Array of archive identifier