Skip to content

Commit d64e4cd

Browse files
authored
Merge pull request #37 from msgflo/fix-topic-convention
Change default queue names
2 parents d6cbf51 + 3eb28b8 commit d64e4cd

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

msgflo/msgflo.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@
3434
import paho.mqtt.client as mqtt
3535

3636
def addDefaultQueue(p, role):
37-
defaultQueue = '%s.%s' % (role, p['id'].upper())
37+
defaultQueue = '%s/%s' % (role, p['id'])
3838
p.setdefault('queue', defaultQueue)
3939
return p
4040

0 commit comments

Comments
 (0)