diff options
Diffstat (limited to 'main.lua')
| -rw-r--r-- | main.lua | 8 |
1 files changed, 4 insertions, 4 deletions
@@ -51,12 +51,12 @@ function Wilson._find_bus(self, channel) end self.log:warn("unfound bus for",channel) end -function Wilson.deliver(self, source_channel, message) - local bus = self:_find_bus(source_channel) +function Wilson.deliver(self, message) + local bus = self:_find_bus(assert(message.source_channel)) if bus then for _, dest_channel in ipairs(bus) do - if source_channel ~= dest_channel then - self.log:debug(source_channel, "-->", dest_channel, message) + if message.source_channel ~= dest_channel then + self.log:debug(message.source_channel, "-->", dest_channel, message) dest_channel.pylon:post(dest_channel, message) end end |