1 files changed, 6 insertions, 2 deletions
diff --git a/streaming/receiver.c b/streaming/receiver.c
index 95652942e9..9378d2d825 100644
--- a/streaming/receiver.c
+++ b/streaming/receiver.c
@@ -332,6 +332,10 @@ static void streaming_parser_thread_cleanup(void *ptr) {
 
 bool plugin_is_enabled(struct plugind *cd);
 
+void streaming_parser_cleanup(void *user) {
+    pluginsd_cleanup_v2(user);
+}
+
 static size_t streaming_parser(struct receiver_state *rpt, struct plugind *cd, int fd, void *ssl) {
     size_t result;
 
@@ -343,7 +347,7 @@ static size_t streaming_parser(struct receiver_state *rpt, struct plugind *cd, i
         .trust_durations = 1
     };
 
-    PARSER *parser = parser_init(rpt->host, &user, NULL, NULL, fd, PARSER_INPUT_SPLIT, ssl);
+    PARSER *parser = parser_init(rpt->host, &user, streaming_parser_cleanup, NULL, NULL, fd, PARSER_INPUT_SPLIT, ssl);
 
     rrd_collector_started();
 
@@ -416,7 +420,7 @@ static size_t streaming_parser(struct receiver_state *rpt, struct plugind *cd, i
     }
 
 done:
-    result = user.count;
+    result = user.data_collections_count;
 
     // free parser with the pop function
     netdata_thread_cleanup_pop(1);