Showing the changes to Source/Libraries/TimeSeriesPlatformLibrary/Samples/SubscriberHandler.cpp (1 of 2 files). Show all
Unified · Split
| @@ -38,11 +38,6 @@ SubscriberHandler::SubscriberHandler(string name) : · 37 unmodified lines | |||
| 38 | { | 38 | { |
| 39 | } | 39 | } |
| 40 | 40 | ||
| 41 | SubscriberHandler::~SubscriberHandler() | ||
| 42 | { | ||
| 43 | cout << "Calling " << m_name << " destructor..."; | ||
| 44 | } | ||
| 45 | |||
| 46 | SubscriptionInfo SubscriberHandler::CreateSubscriptionInfo() | 41 | SubscriptionInfo SubscriberHandler::CreateSubscriptionInfo() |
| 47 | { | 42 | { |
| 48 | SubscriptionInfo info = SubscriberInstance::CreateSubscriptionInfo(); | 43 | SubscriptionInfo info = SubscriberInstance::CreateSubscriptionInfo(); |
| @@ -71,6 +66,8 @@ SubscriptionInfo SubscriberHandler::CreateSubscriptionInfo() · 22 unmodified lines | |||
| 71 | 66 | ||
| 72 | void SubscriberHandler::SetupSubscriberConnector(SubscriberConnector& connector) | 67 | void SubscriberHandler::SetupSubscriberConnector(SubscriberConnector& connector) |
| 73 | { | 68 | { |
| 69 | SubscriberInstance::SetupSubscriberConnector(connector); | ||
| 70 | |||
| 74 | // TODO: Modify connector properties as desired... | 71 | // TODO: Modify connector properties as desired... |
| 75 | //connector.SetMaxRetries(-1); | 72 | //connector.SetMaxRetries(-1); |
| 76 | } | 73 | } |
| @@ -197,8 +194,6 @@ void SubscriberHandler::ReceivedNewMeasurements(const vector<MeasurementPtr>& me · 120 unmodified lines | |||
| 197 | for (const auto& measurement : measurements) | 194 | for (const auto& measurement : measurements) |
| 198 | message << '\t' << measurement->ID << '\t' << measurement->Value << endl; | 195 | message << '\t' << measurement->ID << '\t' << measurement->Value << endl; |
| 199 | 196 | ||
| 200 | message << "Total measurements: " << GetTotalMeasurementsReceived() << endl; | ||
| 201 | |||
| 202 | StatusMessage(message.str()); | 197 | StatusMessage(message.str()); |
| 203 | } | 198 | } |
| 204 | } | 199 | } |