1 files changed, 5 insertions, 5 deletions

diff --git a/apps/mqtt-publish.cpp b/apps/mqtt-publish.cpp
index 25e8ae9..1498b73 100644
--- a/apps/mqtt-publish.cpp
+++ b/apps/mqtt-publish.cpp
@@ -22,12 +22,12 @@ using namespace trygvis::sensor;
 using namespace trygvis::sensor::io;
 using namespace trygvis::mqtt_support;
 
-class MqttSampleOutputStream : public SampleOutputStream {
+class MqttSampleOutputStream : public SampleConsumer {
 public:
     MqttSampleOutputStream(const o<string> &client_id, bool clean_session, string host, unsigned int port,
                            string topic_name,
                            unsigned int keep_alive)
-            : SampleOutputStream(),
+            : SampleConsumer(),
               client(host, port, keep_alive, client_id, clean_session),
               topic_name(topic_name) {
         client.connect();
@@ -37,15 +37,15 @@ public:
         client.disconnect();
     };
 
-    void write(SampleRecord const &sample) override {
+    void onSample(SampleRecord const &sample) override {
         if (sample.empty()) {
             return;
         }
 
         // make a string of the sample
         auto buf = make_shared<stringstream>();
-        KeyValueSampleOutputStream out(buf, sample.dict);
-        out.write(sample);
+        KeyValueWriterSampleConsumer out(buf, sample.dict);
+        out.onSample(sample);
         string s = buf->str();
 
         cout << "sample: " << s;