ImagePusher: Make ZMQStream2Pusher similar to HDF5FilePusher, with a message queue and sending thread

image_pusher/HDF5FilePusher.cpp

@@ -42,10 +42,8 @@ bool HDF5FilePusher::SendImage(const uint8_t *image_data, size_t image_size, int
 }
 
 void HDF5FilePusher::SendImage(ZeroCopyReturnValue &z) {
-    writer_queue.PutBlocking(HDF5FilePusherQueueElement{
+    writer_queue.PutBlocking(ImagePusherQueueElement{
         .image_data = (uint8_t *) z.GetImage(),
-        .image_size = z.GetImageSize(),
-        .image_number = z.GetImageNumber(),
         .z = &z,
         .end = false
     });
@@ -60,9 +58,9 @@ bool HDF5FilePusher::SendCalibration(const CompressedImage &message) {
 }
 
 void HDF5FilePusher::WriterThread() {
-    HDF5FilePusherQueueElement e = writer_queue.GetBlocking();
+    ImagePusherQueueElement e = writer_queue.GetBlocking();
     while (!e.end) {
-        SendImage(e.image_data, e.image_size, e.image_number);
+        SendImage(e.image_data, e.z->GetImageSize(), e.z->GetImageNumber());
         e.z->release();
         e = writer_queue.GetBlocking();
     }