diff --git a/agkyra/agkyra/syncer/syncer.py b/agkyra/agkyra/syncer/syncer.py index 131dd67b610a5daffef452aaf20561d211c3b8c7..07c5cda45774d356513a4775efcf86ff9b6a735e 100644 --- a/agkyra/agkyra/syncer/syncer.py +++ b/agkyra/agkyra/syncer/syncer.py @@ -69,8 +69,8 @@ class FileSyncer(object): if self.decide_event is not None: self.decide_event.clear() - def get_next_message(self): - return self.messager.get(block=False) + def get_next_message(self, block=False): + return self.messager.get(block=block) def exclude_file(self, objname): parts = objname.split(common.OBJECT_DIRSEP)