kapitan/IXWebSocket
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

cout -> spdlog

Browse Source
This commit is contained in:
Benjamin Sergeant 2019-05-10 12:33:21 -07:00
parent 3df142db7a
commit 88adbf0ca2
2 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
third_party/statsd-client-cpp/src/statsd_client.cpp vendored
View File

@ -221,7 +221,6 @@ int StatsdClient::send(const string &message)
int StatsdClient::send_to_daemon(const string &message) { int StatsdClient::send_to_daemon(const string &message) {
std::cout << "send_to_daemon: " << message.length() << " B" << std::endl;
int ret = init(); int ret = init();
if ( ret ) if ( ret )
{ {

19
ws/ws_cobra_to_statsd.cpp
View File

@ -13,6 +13,7 @@
#include <ixcobra/IXCobraConnection.h> #include <ixcobra/IXCobraConnection.h>
#include <statsd_client.h> #include <statsd_client.h>
#include <spdlog/spdlog.h>
namespace ix namespace ix
{ {
@ -90,20 +91,20 @@ namespace ix
{ {
if (eventType == ix::CobraConnection_EventType_Open) if (eventType == ix::CobraConnection_EventType_Open)
{ {
std::cout << "Subscriber: connected" << std::endl; spdlog::info("Subscriber connected");
for (auto it : headers) for (auto it : headers)
{ {
std::cerr << it.first << ": " << it.second << std::endl; spdlog::info("{}: {}", it.first, it.second);
} }
} }
if (eventType == ix::CobraConnection_EventType_Closed) if (eventType == ix::CobraConnection_EventType_Closed)
{ {
std::cout << "Subscriber: closed" << std::endl; spdlog::info("Subscriber closed");
} }
else if (eventType == ix::CobraConnection_EventType_Authenticated) else if (eventType == ix::CobraConnection_EventType_Authenticated)
{ {
std::cout << "Subscriber authenticated" << std::endl; spdlog::info("Subscriber authenticated");
conn.subscribe(channel, conn.subscribe(channel,
[&jsonWriter, &statsdClient, [&jsonWriter, &statsdClient,
verbose, &tokens, &prefix, &msgCount] verbose, &tokens, &prefix, &msgCount]
@ -111,7 +112,7 @@ namespace ix
{ {
if (verbose) if (verbose)
{ {
std::cout << jsonWriter.write(msg) << std::endl; spdlog::info(jsonWriter.write(msg));
} }
std::string id; std::string id;
@ -121,22 +122,22 @@ namespace ix
id += extractAttr(attr, msg); id += extractAttr(attr, msg);
} }
std::cout << msgCount++ << " " << prefix << id << std::endl; spdlog::info("{} {}{}", msgCount++, prefix, id);
statsdClient.count(id, 1); statsdClient.count(id, 1);
}); });
} }
else if (eventType == ix::CobraConnection_EventType_Subscribed) else if (eventType == ix::CobraConnection_EventType_Subscribed)
{ {
std::cout << "Subscriber: subscribed to channel " << subscriptionId << std::endl; spdlog::info("Subscriber: subscribed to channel {}", subscriptionId);
} }
else if (eventType == ix::CobraConnection_EventType_UnSubscribed) else if (eventType == ix::CobraConnection_EventType_UnSubscribed)
{ {
std::cout << "Subscriber: unsubscribed from channel " << subscriptionId << std::endl; spdlog::info("Subscriber: unsubscribed from channel {}", subscriptionId);
} }
else if (eventType == ix::CobraConnection_EventType_Error) else if (eventType == ix::CobraConnection_EventType_Error)
{ {
std::cout << "Subscriber: error" << errMsg << std::endl; spdlog::error("Subscriber: error {}", errMsg);
} }
} }
); );