From 67f0626555fa2eb65b02b477353a4336df86695b Mon Sep 17 00:00:00 2001 From: Johan Egneblad Date: Wed, 10 Aug 2016 18:47:39 +0100 Subject: [PATCH] Make STOMP listener expand vars in stomp url from config --- flow/source/stomp.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/flow/source/stomp.py b/flow/source/stomp.py index f3f34cb..2b3aaa1 100644 --- 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):