src/PosixMQCommand.h
branchv_0
changeset 7 12e975f807ed
parent 2 1eef3d465863
equal deleted inserted replaced
6:65abb0376a0d 7:12e975f807ed
    18 
    18 
    19 #include <iostream>
    19 #include <iostream>
    20 #include <sstream>
    20 #include <sstream>
    21 #include <vector>
    21 #include <vector>
    22 #include <memory>
    22 #include <memory>
       
    23 #include <atomic>
    23 
    24 
    24 #include <relpipe/writer/TypeId.h>
    25 #include <relpipe/writer/TypeId.h>
    25 
    26 
    26 #include "Configuration.h"
    27 #include "Configuration.h"
    27 
    28 
    30 namespace posixmq {
    31 namespace posixmq {
    31 
    32 
    32 class PosixMQCommand {
    33 class PosixMQCommand {
    33 private:
    34 private:
    34 	std::wstring_convert<codecvt_utf8<wchar_t>> convertor; // TODO: support also other encodings.
    35 	std::wstring_convert<codecvt_utf8<wchar_t>> convertor; // TODO: support also other encodings.
       
    36 	std::atomic<bool> continueProcessing{true};
    35 public:
    37 public:
    36 	virtual ~PosixMQCommand();
    38 	virtual ~PosixMQCommand();
    37 
    39 
    38 	void process(std::shared_ptr<writer::RelationalWriter> writer, Configuration& configuration);
    40 	void process(std::shared_ptr<writer::RelationalWriter> writer, Configuration& configuration);
       
    41 
       
    42 	void finish(int sig) {
       
    43 		continueProcessing = false;
       
    44 	}
    39 
    45 
    40 };
    46 };
    41 
    47 
    42 }
    48 }
    43 }
    49 }