'Process the new file and add to the file store.'

@flow.EventHandler()
def ProcessMessage(self, message=None, event=None):

    _ = event
    vfs_urn = message.payload
    vfs_fd = aff4.FACTORY.Open(vfs_urn, mode='rw', token=self.token)
    filestore_fd = aff4.FACTORY.Create(filestore.FileStore.PATH, filestore.FileStore, mode='w', token=self.token)
    filestore_fd.AddFile(vfs_fd)
    vfs_fd.Flush(sync=False)
