--- a/src/PosixMQHandler.h	Fri Mar 04 01:40:50 2022 +0100
+++ b/src/PosixMQHandler.h	Fri Mar 04 21:30:08 2022 +0100
@@ -30,6 +30,7 @@
 #include <relpipe/reader/handlers/AttributeMetadata.h>
 
 #include "PosixMQ.h"
+#include "Configuration.h"
 
 namespace relpipe {
 namespace out {
@@ -38,14 +39,13 @@
 class PosixMQHandler : public relpipe::reader::handlers::RelationalReaderStringHandler {
 private:
 	std::wstring_convert<codecvt_utf8<wchar_t>> convertor; // TODO: support also other encodings.
+	Configuration configuration;
 	shared_ptr<PosixMQ> mq;
 
 public:
 
-	PosixMQHandler(std::ostream& output) {
-		relpipe::common::type::StringX queueName = L"/relpipe";
-		mq.reset(PosixMQ::open(convertor.to_bytes(queueName)));
-
+	PosixMQHandler(Configuration configuration) : configuration(configuration) {
+		mq.reset(PosixMQ::open(convertor.to_bytes(configuration.queue), configuration.unlinkOnClose));
 	}
 
 	void startRelation(relpipe::common::type::StringX name, std::vector<relpipe::reader::handlers::AttributeMetadata> attributes) override {