For all multi-part messages, check the headers. If the header is not your minion_id, skip the message

Fix for #26844
This commit is contained in:
Thomas Jackson 2015-10-19 09:05:31 -07:00
parent d4604fdb26
commit 75e04bcbbc

View file

@ -2011,6 +2011,9 @@ class Minion(MinionBase):
payload = self.serial.loads(messages[0])
# 2 includes a header which says who should do it
elif messages_len == 2:
if messages[0] not in ('broadcast', self.hexid):
log.debug('Publish recieved for not this minion: {0}'.format(messages[0]))
return
payload = self.serial.loads(messages[1])
else:
raise Exception(('Invalid number of messages ({0}) in zeromq pub'