equal
deleted
inserted
replaced
42 namespace posixmq { |
42 namespace posixmq { |
43 |
43 |
44 void PosixMQCommand::process(std::shared_ptr<writer::RelationalWriter> writer, Configuration& configuration) { |
44 void PosixMQCommand::process(std::shared_ptr<writer::RelationalWriter> writer, Configuration& configuration) { |
45 vector<AttributeMetadata> metadata; |
45 vector<AttributeMetadata> metadata; |
46 |
46 |
47 std::shared_ptr<PosixMQ> mq(PosixMQ::open(convertor.to_bytes(configuration.queue))); |
47 std::shared_ptr<PosixMQ> mq(PosixMQ::open(convertor.to_bytes(configuration.queue), configuration.unlinkOnClose)); |
48 |
48 |
49 writer->startRelation(configuration.relation,{ |
49 writer->startRelation(configuration.relation,{ |
50 {L"queue", TypeId::STRING}, |
50 {L"queue", TypeId::STRING}, |
51 {L"message", TypeId::STRING} |
51 {L"message", TypeId::STRING} |
52 }, true); |
52 }, true); |