1 files changed, 7 insertions, 2 deletions
diff --git a/src/BootstrapNode.cpp b/src/BootstrapNode.cpp
index f7fe738..9edf008 100644
--- a/src/BootstrapNode.cpp
+++ b/src/BootstrapNode.cpp
@@ -88,16 +88,21 @@ namespace sibs
         serializer.add((u16)newPeer->address.address.sin_port);
         std::shared_ptr<std::vector<u8>> serializerData = std::make_shared<std::vector<u8>>(std::move(serializer.getBuffer()));
         
+        auto sendCallbackFunc = [](PubSubResult result, const std::string &resultStr)
+        {
+            Log::debug("BootstrapNode::peerSubscribe send result: %d, result string: %s", result, resultStr.c_str());
+        };
+        
         sibs::SafeSerializer newPeerSerializer;
         newPeerSerializer.add(pubsubKey.data.data(), pubsubKey.data.size());
         for(auto &peer : peers)
         {
-            connections.send(peer, serializerData);
+            connections.send(peer, serializerData, sendCallbackFunc);
             newPeerSerializer.add((u32)peer->address.address.sin_family);
             newPeerSerializer.add((u32)peer->address.address.sin_addr.s_addr);
             newPeerSerializer.add((u16)peer->address.address.sin_port);
         }
         peers.push_back(newPeer);
-        connections.send(newPeer, std::make_shared<std::vector<u8>>(std::move(newPeerSerializer.getBuffer())));
+        connections.send(newPeer, std::make_shared<std::vector<u8>>(std::move(newPeerSerializer.getBuffer())), sendCallbackFunc);
     }
 }