Make STOMP listener expand vars in stomp url from config

eblade · Aug 10, 2016 · 67f0626 · 67f0626
1 parent 92680af
commit 67f0626
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/flow/source/stomp.py b/flow/source/stomp.py
@@ -1,3 +1,5 @@
+import os
+
 from ..needs import NeedsStomp
 from ..base import EventBased
 
@@ -28,7 +30,7 @@ def start(self, message):
                 pass
     """
     def __init__(self, stomp_url):
-        self.stomp_url = stomp_url
+        self.stomp_url = os.path.expandvars(stomp_url)
         self.callback = None
 
     def run(self):