zephyr_mirror: Fix syncing instances of class message.
(imported from commit dfbbce336145ef6233eab27120a1ccefda055b13)
This commit is contained in:
parent
7ac10e626c
commit
07c190d94b
|
@ -140,10 +140,10 @@ def send_humbug(zeph):
|
||||||
# Forward messages sent to -c foo -i bar to stream bar subject "instance"
|
# Forward messages sent to -c foo -i bar to stream bar subject "instance"
|
||||||
if zeph["stream"] == "message":
|
if zeph["stream"] == "message":
|
||||||
message['stream'] = zeph['subject'].lower()
|
message['stream'] = zeph['subject'].lower()
|
||||||
message['subject'] = "instance %s" % (zeph['stream'])
|
message['subject'] = "instance %s" % (zeph['subject'])
|
||||||
elif zeph["stream"] == "tabbott-test5":
|
elif zeph["stream"] == "tabbott-test5":
|
||||||
message['stream'] = zeph['subject'].lower()
|
message['stream'] = zeph['subject'].lower()
|
||||||
message['subject'] = "test instance %s" % (zeph['stream'])
|
message['subject'] = "test instance %s" % (zeph['subject'])
|
||||||
else:
|
else:
|
||||||
message["stream"] = zeph["stream"]
|
message["stream"] = zeph["stream"]
|
||||||
else:
|
else:
|
||||||
|
|
Loading…
Reference in a new issue