--- 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},