From ad51e0debedc8b80b63f1814ef11cf316edc13bf Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Odd=20Str=C3=A5b=C3=B8?= <oddstr13@openshell.no>
Date: Sat, 7 Jan 2023 18:59:36 +0100
Subject: [PATCH] Add StdoutConsumer

---
 srnemqtt/consumers/stdio.py | 16 ++++++++++++++++
 1 file changed, 16 insertions(+)
 create mode 100644 srnemqtt/consumers/stdio.py

diff --git a/srnemqtt/consumers/stdio.py b/srnemqtt/consumers/stdio.py
new file mode 100644
index 0000000..df63e70
--- /dev/null
+++ b/srnemqtt/consumers/stdio.py
@@ -0,0 +1,16 @@
+# -*- coding: utf-8 -*-
+import json
+from typing import Any, Dict
+
+from . import BaseConsumer
+
+
+class StdoutConsumer(BaseConsumer):
+    def __init__(self, settings: Dict[str, Any]) -> None:
+        super().__init__(settings)
+
+    def poll(self):
+        return super().poll()
+
+    def write(self, data: Dict[str, Any]):
+        print(json.dumps(data))