diff --git a/owrx/source.py b/owrx/source.py
index 7d62388..3f1b2ac 100644
--- a/owrx/source.py
+++ b/owrx/source.py
@@ -2,6 +2,7 @@ import subprocess
 from owrx.config import PropertyManager
 from owrx.feature import FeatureDetector, UnknownFeatureException
 from owrx.meta import MetaParser
+from owrx.wsjt import WsjtParser
 import threading
 import csdr
 import time
@@ -346,6 +347,7 @@ class DspManager(csdr.output):
         self.handler = handler
         self.sdrSource = sdrSource
         self.metaParser = MetaParser(self.handler)
+        self.wsjtParser = WsjtParser(self.handler)
 
         self.localProps = self.sdrSource.getProps().collect(
             "audio_compression", "fft_compression", "digimodes_fft_size", "csdr_dynamic_bufsize",
@@ -417,7 +419,8 @@ class DspManager(csdr.output):
             "smeter": self.handler.write_s_meter_level,
             "secondary_fft": self.handler.write_secondary_fft,
             "secondary_demod": self.handler.write_secondary_demod,
-            "meta": self.metaParser.parse
+            "meta": self.metaParser.parse,
+            "wsjt_demod": self.wsjtParser.parse
         }
         write = writers[t]