def processIncomingMessages(self):
        while not self.isShuttingDown:
            message = self.channel.get()
            if message == InMemoryTransport.DisconnectMessage:
                self.onDisconnected()
                return

            try:
                self.onMessageReceived(message)
            except TypeError as e:
                print (e, message) % 'Error decoding message: %s\nMessage: %s'
dataset/ETHPy150Open ufora/ufora/ufora/networking/InMemoryTransport.py/InMemoryTransport.processIncomingMessages/swapped operands of `%`