equal
deleted
inserted
replaced
53 {L"queue", TypeId::STRING}, |
53 {L"queue", TypeId::STRING}, |
54 {L"text", TypeId::STRING}, |
54 {L"text", TypeId::STRING}, |
55 {L"data", TypeId::STRING} |
55 {L"data", TypeId::STRING} |
56 }, true); |
56 }, true); |
57 |
57 |
58 for (int i = configuration.messageCount; i > 0; i--) { |
58 for (int i = configuration.messageCount; continueProcessing && i > 0; i--) { |
|
59 // TODO: maybe rather call mq_timedreceive() inside and check continueProcessing (to be able to stop even when no messages are comming) |
59 std::string message = mq->receive(); |
60 std::string message = mq->receive(); |
60 |
61 |
61 writer->writeAttribute(configuration.queue); |
62 writer->writeAttribute(configuration.queue); |
62 writer->writeAttribute(Hex::toTxt(message)); |
63 writer->writeAttribute(Hex::toTxt(message)); |
63 writer->writeAttribute(Hex::toHex(message)); |
64 writer->writeAttribute(Hex::toHex(message)); |