Index: /trunk/FACT++/src/EventBuilder.cc
===================================================================
--- /trunk/FACT++/src/EventBuilder.cc	(revision 17235)
+++ /trunk/FACT++/src/EventBuilder.cc	(revision 17236)
@@ -11,5 +11,5 @@
 #include <boost/algorithm/string/join.hpp>
 
-#include "queue.h"
+#include "../externals/Queue.h"
 
 #include "MessageImp.h"
@@ -802,11 +802,12 @@
 // ==========================================================================
 
-void proc1(const shared_ptr<EVT_CTRL2> &);
+bool proc1(const shared_ptr<EVT_CTRL2> &);
 
 Queue<shared_ptr<EVT_CTRL2>> processingQueue1(bind(&proc1, placeholders::_1));
 
-void proc1(const shared_ptr<EVT_CTRL2> &evt)
+bool proc1(const shared_ptr<EVT_CTRL2> &evt)
 {
     applyCalib(*evt, processingQueue1.size());
+    return true;
 }
 
@@ -814,5 +815,5 @@
 // a command queue, to which command+data is posted,
 // (e.g. runOpen+runInfo, runClose+runInfo, evtWrite+evtInfo)
-void writeEvt(const shared_ptr<EVT_CTRL2> &evt)
+bool writeEvt(const shared_ptr<EVT_CTRL2> &evt)
 {
     //const shared_ptr<RUN_CTRL2> &run = evt->runCtrl;
@@ -832,5 +833,5 @@
                 factPrintf(MessageImp::kError, "Could not open new file for run %d (evt=%d, runOpen failed)", evt->runNum, evt->evNum);
                 run.fileStat = kFileClosed;
-                return;
+                return true;
             }
 
@@ -846,5 +847,5 @@
     // File already closed
     if (run.fileStat==kFileClosed)
-        return;
+        return true;
 
     bool rc1 = true;
@@ -859,9 +860,9 @@
     // ... this is the case if CloseRunFile was called before any file was opened.
     if (run.fileStat!=kFileOpen)
-        return;
+        return true;
 
     // File is not yet to be closed.
     if (rc1 && evt->closeRequest==kRequestNone)
-        return;
+        return true;
 
     runClose(run);
@@ -886,9 +887,11 @@
     const string str = boost::algorithm::join(reason, ", ");
     factPrintf(MessageImp::kInfo, "File closed because %s",  str.c_str());
+
+    return true;
 }
 
 Queue<shared_ptr<EVT_CTRL2>> secondaryQueue(bind(&writeEvt, placeholders::_1));
 
-void procEvt(const shared_ptr<EVT_CTRL2> &evt)
+bool procEvt(const shared_ptr<EVT_CTRL2> &evt)
 {
     if (evt->valid())
@@ -914,5 +917,5 @@
         {
             secondaryQueue.emplace(new EVT_CTRL2(kRequestEventCheckFailed, evt->runCtrl));
-            return;
+            return true;
         }
     }
@@ -920,4 +923,6 @@
     // If file is open post the event for being written
     secondaryQueue.post(evt);
+
+    return true;
 }