add quick start c++ examples

examples/consumer/simple-consumer/CMakeLists.txt

+cmake_minimum_required(VERSION 2.8)
+
+project(asapo-consume)
+
+set(CMAKE_CXX_STANDARD 11)
+
+IF(CMAKE_C_COMPILER_ID STREQUAL "GNU")
+    SET( CMAKE_EXE_LINKER_FLAGS  "${CMAKE_EXE_LINKER_FLAGS} -static-libgcc -static-libstdc++")
+ENDIF()
+
+find_package (Threads)
+
+set(TARGET_NAME ${CMAKE_PROJECT_NAME})
+
+set(SOURCE_FILES consume.cpp)
+
+link_directories(asapo/lib)
+
+add_executable(${TARGET_NAME} ${SOURCE_FILES})
+target_include_directories(${TARGET_NAME} PUBLIC asapo/include)
+target_link_libraries(${TARGET_NAME} asapo-consumer curl ${CMAKE_THREAD_LIBS_INIT})

examples/consumer/simple-consumer/consume.cpp

+#include "asapo_consumer.h"
+
+void exit_if_error(std::string error_string, const asapo::Error& err) {
+    if (err) {
+        std::cerr << error_string << err << std::endl;
+        exit(EXIT_FAILURE);
+    }
+}
+
+int main(int argc, char* argv[]) {
+    asapo::Error err;
+
+    auto endpoint = "asapo-services2:8400";
+    auto beamtime = "asapo_test";
+    auto token = "KmUDdacgBzaOD3NIJvN1NmKGqWKtx0DK-NyPjdpeWkc=";
+
+    auto broker = asapo::DataBrokerFactory::CreateServerBroker(endpoint, "", true, asapo::SourceCredentials{beamtime, "", "", token}, &err);
+    exit_if_error("Cannot create consumer", err);
+    broker->SetTimeout((uint64_t) 1000);
+
+    auto group_id = broker->GenerateNewGroupId(&err);
+    exit_if_error("Cannot create group id", err);
+
+    asapo::FileInfo fi;
+    asapo::FileData data;
+
+    err = broker->GetLast(&fi, group_id, &data);
+    exit_if_error("Cannot get next record", err);
+
+    std::cout << "id: " << fi.id << std::endl;
+    std::cout << "file name: " << fi.name << std::endl;
+    std::cout << "file content: " << reinterpret_cast<char const*>(data.get()) << std::endl;
+    return EXIT_SUCCESS;
+}
+

examples/producer/simple-producer/CMakeLists.txt

+cmake_minimum_required(VERSION 2.8)
+
+project(asapo-produce)
+
+set(CMAKE_CXX_STANDARD 11)
+
+IF(CMAKE_C_COMPILER_ID STREQUAL "GNU")
+    SET( CMAKE_EXE_LINKER_FLAGS  "${CMAKE_EXE_LINKER_FLAGS} -static-libgcc -static-libstdc++")
+ENDIF()
+
+find_package (Threads)
+
+set(TARGET_NAME ${CMAKE_PROJECT_NAME})
+
+set(SOURCE_FILES produce.cpp)
+
+link_directories(asapo/lib)
+
+add_executable(${TARGET_NAME} ${SOURCE_FILES})
+target_include_directories(${TARGET_NAME} PUBLIC asapo/include)
+target_link_libraries(${TARGET_NAME} asapo-producer curl  ${CMAKE_THREAD_LIBS_INIT})

examples/producer/simple-producer/produce.cpp

+#include "asapo_producer.h"
+
+void ProcessAfterSend(asapo::GenericRequestHeader header, asapo::Error err) {
+    if (err) {
+        std::cerr << "error/warnign during send: " << err << std::endl;
+        return;
+    } else {
+        std::cout << "successfuly send " << header.Json() << std::endl;
+        return;
+    }
+}
+
+
+void exit_if_error(std::string error_string, const asapo::Error& err) {
+    if (err) {
+        std::cerr << error_string << err << std::endl;
+        exit(EXIT_FAILURE);
+    }
+}
+
+
+int main(int argc, char* argv[]) {
+    asapo::Error err;
+
+    auto source = "asapo-services2:8400";
+    auto beamtime = "asapo_test";
+
+    auto producer = asapo::Producer::Create(source, 1,asapo::RequestHandlerType::kTcp,
+                                            asapo::SourceCredentials{beamtime, "", "", ""}, 60, &err);
+    exit_if_error("Cannot start producer", err);
+
+    std::string to_send = "hello";
+    auto send_size = to_send.size() + 1;
+    auto buffer =  asapo::FileData(new uint8_t[send_size]);
+    memcpy(buffer.get(),to_send.c_str(),send_size);
+
+    asapo::EventHeader event_header{1, send_size, "test_file"};
+    err = producer->SendData(event_header, std::move(buffer), asapo::kDefaultIngestMode, &ProcessAfterSend);
+    exit_if_error("Cannot send file", err);
+
+    err = producer->WaitRequestsFinished(1000);
+    exit_if_error("Producer exit on timeout", err);
+
+    return EXIT_SUCCESS;
+}
+