Skip to content

Commit 3eb28b8

Browse files
committed
Change default queue names to role/port [BREAKING]
This matches common conventions in MQTT and other systems better, using / to denote hierarchies of topics/queues. If the old convention is needed, explicity specify 'queue' as part of Participant defintition
1 parent d6cbf51 commit 3eb28b8

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)