zephyr_mirror: Don't force-lower-case instance names.
(imported from commit 5b9b450ae7666a9c74704a7bd494c57a47578fe7)
This commit is contained in:
parent
ad6cc113a3
commit
cf92525270
|
@ -103,10 +103,10 @@ def send_humbug(zeph):
|
||||||
if zeph['type'] == 'stream':
|
if zeph['type'] == 'stream':
|
||||||
# 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']
|
message['stream'] = zeph['subject'].lower()
|
||||||
message['subject'] = "instance %s" % (zeph['stream'])
|
message['subject'] = "instance %s" % (zeph['stream'])
|
||||||
elif zeph["stream"] == "tabbott-test5":
|
elif zeph["stream"] == "tabbott-test5":
|
||||||
message['stream'] = zeph['subject']
|
message['stream'] = zeph['subject'].lower()
|
||||||
message['subject'] = "test instance %s" % (zeph['stream'])
|
message['subject'] = "test instance %s" % (zeph['stream'])
|
||||||
else:
|
else:
|
||||||
message["stream"] = zeph["stream"]
|
message["stream"] = zeph["stream"]
|
||||||
|
@ -271,7 +271,7 @@ def process_notice(notice, log):
|
||||||
zeph['type'] = 'stream'
|
zeph['type'] = 'stream'
|
||||||
zeph['stream'] = zephyr_class
|
zeph['stream'] = zephyr_class
|
||||||
if notice.instance != "":
|
if notice.instance != "":
|
||||||
zeph['subject'] = notice.instance.lower()
|
zeph['subject'] = notice.instance
|
||||||
else:
|
else:
|
||||||
zeph["subject"] = "personal"
|
zeph["subject"] = "personal"
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue