Showing the changes to Source/Libraries/TimeSeriesPlatformLibrary/Samples/AdvancedSubscribe.cpp (1 of 6 files). Show all
Unified · Split
| @@ -105,6 +105,7 @@ void RunSubscriber(string hostname, uint16_t port) · 104 unmodified lines | ||
| 105 | 105 | // Register callbacks |
| 106 | 106 | Subscriber.RegisterStatusMessageCallback(&DisplayStatusMessage); |
| 107 | 107 | Subscriber.RegisterErrorMessageCallback(&DisplayErrorMessage); |
| 108 | + Subscriber.RegisterNewMeasurementsCallback(&ProcessMeasurements); | |
| 108 | 109 | |
| 109 | 110 | cout << endl << "Connecting to " << hostname << ":" << port << "..." << endl << endl; |
| 110 | 111 | |
| @@ -141,7 +142,6 @@ SubscriptionInfo CreateSubscriptionInfo() · 30 unmodified lines | ||
| 141 | 142 | //info.FilterExpression = "FILTER ActiveMeasurements WHERE Device = 'SHELBY' AND SignalType = 'FREQ'"; |
| 142 | 143 | |
| 143 | 144 | info.FilterExpression = "PPA:1;PPA:2;PPA:3;PPA:4;PPA:5;PPA:6;PPA:7;PPA:8;PPA:9;PPA:10;PPA:11;PPA:12;PPA:13;PPA:14"; |
| 144 | − info.NewMeasurementsCallback = &ProcessMeasurements; | |
| 145 | 145 | |
| 146 | 146 | // To set up a remotely synchronized subscription, set this flag |
| 147 | 147 | // to true and add the framesPerSecond parameter to the |