src/PosixMQCommand.cpp
branchv_0
changeset 3 b71fc3b5e56b
parent 2 1eef3d465863
child 4 f9d43c5adae9
--- a/src/PosixMQCommand.cpp	Tue Mar 01 00:49:46 2022 +0100
+++ b/src/PosixMQCommand.cpp	Fri Mar 04 19:43:16 2022 +0100
@@ -44,7 +44,7 @@
 void PosixMQCommand::process(std::shared_ptr<writer::RelationalWriter> writer, Configuration& configuration) {
 	vector<AttributeMetadata> metadata;
 
-	std::shared_ptr<PosixMQ> mq(PosixMQ::open(convertor.to_bytes(configuration.queue)));
+	std::shared_ptr<PosixMQ> mq(PosixMQ::open(convertor.to_bytes(configuration.queue), configuration.unlinkOnClose));
 
 	writer->startRelation(configuration.relation,{
 		{L"queue", TypeId::STRING},