Break module iteration if the message has been consumed by any of the modules

1 files changed, 3 insertions, 0 deletions

diff --git a/wallace/__init__.py b/wallace/__init__.py
index 6e41654..6698666 100644
--- a/wallace/__init__.py
+++ b/wallace/__init__.py
@@ -80,6 +80,9 @@ def pickup_message(filepath, *args, **kw):
         else:
             # A module has returned False or None
             continue_with_accept = False
+            # The message very likely has been consumed by the module that returned False
+            if not os.path.isfile(filepath):
+                break
 
     if continue_with_accept:
         cb_action_ACCEPT('wallace', filepath)