diff --git a/csaxs/CsaxsFormat.cpp b/csaxs/CsaxsFormat.cpp
index 9bba396..75b386c 100644
--- a/csaxs/CsaxsFormat.cpp
+++ b/csaxs/CsaxsFormat.cpp
@@ -17,7 +17,7 @@ class CsaxsFormat : public H5Format
     public:
         ~CsaxsFormat(){};
 
-        CsaxsFormat(const string& dataset_name, int n_bad_modules)
+        CsaxsFormat(const string& dataset_name)
         {
            
             // After format has been writen, where to move the raw datasets.
diff --git a/csaxs/csaxs_h5_writer.cpp b/csaxs/csaxs_h5_writer.cpp
new file mode 100644
index 0000000..4af0bc1
--- /dev/null
+++ b/csaxs/csaxs_h5_writer.cpp
@@ -0,0 +1,53 @@
+#include <iostream>
+#include <sstream>
+#include <stdexcept>
+
+#include "config.hpp"
+#include "WriterManager.hpp"
+#include "ZmqReceiver.hpp"
+#include "ProcessManager.hpp"
+
+#include "CsaxsFormat.cpp"
+
+int main (int argc, char *argv[])
+{
+    if (argc != 6) {
+        cout << endl;
+        cout << "Usage: csaxs_h5_writer [connection_address] [output_file] [n_frames]";
+        cout << " [rest_port] [user_id]" << endl;
+        cout << "\tconnection_address: Address to connect to the stream (PULL). Example: tcp://127.0.0.1:40000" << endl;
+        cout << "\toutput_file: Name of the output file." << endl;
+        cout << "\tn_frames: Number of images to acquire. 0 for infinity (until /stop is called)." << endl;
+        cout << "\trest_port: Port to start the REST Api on." << endl;
+        cout << "\tuser_id: uid under which to run the writer. -1 to leave it as it is." << endl;
+        cout << endl;
+
+        exit(-1);
+    }
+
+    string connect_address = string(argv[1]);
+    string output_file = string(argv[2]);
+    int n_frames =  atoi(argv[3]);
+    int rest_port = atoi(argv[4]);
+    int user_id = atoi(argv[5]);
+    string bsread_rest_address = "http://localhost:9999/";
+
+    if (user_id != -1) {
+        writer_utils::set_process_id(user_id);
+    }
+
+    writer_utils::create_destination_folder(output_file);   
+
+    auto header_values = shared_ptr<unordered_map<string, HeaderDataType>>();
+
+    CsaxsFormat format(detector_name, n_bad_modules);
+
+    WriterManager writer_manager(format.get_input_value_type(), output_file, n_frames);
+    ZmqReceiver receiver(connect_address, config::zmq_n_io_threads, config::zmq_receive_timeout, header_values);
+    RingBuffer ring_buffer(config::ring_buffer_n_slots);
+
+    ProcessManager process_manager(writer_manager, receiver, ring_buffer, format, rest_port, bsread_rest_address);
+    process_manager.run_writer();
+
+    return 0;
+}