Fix file manager using single msg queue.
This commit is contained in:
parent
92a6b86ccd
commit
853efa6968
1 changed files with 6 additions and 3 deletions
|
@ -65,11 +65,14 @@ class FileManager:
|
||||||
else:
|
else:
|
||||||
try:
|
try:
|
||||||
|
|
||||||
split = message.split(":", 1)
|
split = message.split(":", 3)
|
||||||
|
|
||||||
channel = int(split[0])
|
channel = int(split[0])
|
||||||
# source = split[1]
|
# source = split[1]
|
||||||
command = split[2]
|
command = split[2]
|
||||||
|
# rest of message = split[3]
|
||||||
|
|
||||||
|
self.logger.log.debug("Got command {} for channel {}".format(command,channel))
|
||||||
|
|
||||||
# If we have requested a new show plan, empty the music-tmp directory for the previous show.
|
# If we have requested a new show plan, empty the music-tmp directory for the previous show.
|
||||||
if command == "GETPLAN":
|
if command == "GETPLAN":
|
||||||
|
@ -150,8 +153,8 @@ class FileManager:
|
||||||
|
|
||||||
except Exception:
|
except Exception:
|
||||||
self.logger.log.exception(
|
self.logger.log.exception(
|
||||||
"Failed to handle message {} on channel {}.".format(
|
"Failed to handle message {}.".format(
|
||||||
message, channel
|
message
|
||||||
)
|
)
|
||||||
)
|
)
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue