Fix logging for stream layer read example. (#754)

* Fix logging for stream layer read example.

Add logs on subscription/unsubscription/start example.

Resolves: OLPEDGE-1743

Signed-off-by: Liubov Didkivska <[email protected]>

Author: Liubov Didkivska

examples/StreamLayerReadExample.cpp

@@ -46,6 +46,9 @@ bool CreateSubscription(StreamLayerClient& client,
         subscribe_response.GetError().GetMessage().c_str());
     return false;
   }
+  OLP_SDK_LOG_INFO_F(kLogTag,
+                     "Client subscribe successfuly (subscription_id=%s)",
+                     subscribe_response.GetResult().c_str());
   return true;
 }
 
@@ -107,7 +110,6 @@ void RunPoll(StreamLayerClient& client) {
     auto messages_size = GetDataFromMessages(client, result);
     total_messages_size += messages_size;
     if (!messages_size) {
-      OLP_SDK_LOG_INFO(kLogTag, "No new messages is received");
       break;
     }
   }
@@ -130,6 +132,7 @@ bool DeleteSubscription(StreamLayerClient& client) {
                         unsubscribe_response.GetError().GetMessage().c_str());
     return false;
   }
+  OLP_SDK_LOG_INFO(kLogTag, "Client unsubscribe successfuly");
   return true;
 }
 }  // namespace
@@ -138,6 +141,12 @@ int RunStreamLayerExampleRead(
     const AccessKey& access_key, const std::string& catalog,
     const std::string& layer_id,
     SubscribeRequest::SubscriptionMode subscription_mode) {
+  OLP_SDK_LOG_INFO_F(
+      kLogTag, "Starting stream layer read, catalog=%s, layer=%s, mode=%s",
+      catalog.c_str(), layer_id.c_str(),
+      (subscription_mode == SubscribeRequest::SubscriptionMode::kParallel)
+          ? "parallel"
+          : "serial");
   // Create a task scheduler instance
   std::shared_ptr<olp::thread::TaskScheduler> task_scheduler =
       olp::client::OlpClientSettingsFactory::CreateDefaultTaskScheduler();