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