This commit is contained in:
2023-10-09 22:51:54 +03:00
parent c43cb7bfe6
commit 94e77b4607
3 changed files with 7 additions and 12 deletions

View File

@@ -66,6 +66,7 @@ public abstract class RepositoryServer<D extends Database> {
}
protected Thread interruptThread = new InterruptThread(10000,
() -> {
System.out.println("INTERRUPT FILE FOUND");
System.exit(0);
return null;
});
@@ -99,7 +100,7 @@ public abstract class RepositoryServer<D extends Database> {
}
//------------------------------
for (String target : message_in.targets) {
System.out.println("target="+target);
System.out.println("target=" + target);
if (needsEmail(target)) {
System.out.println("needs email");
try {
@@ -141,11 +142,11 @@ public abstract class RepositoryServer<D extends Database> {
ex.printStackTrace();
Print(ex.getMessage());
}
}else System.out.println("does not need email");
} else System.out.println("does not need email");
}
System.out.println("EMAIL ENDED");
}
public boolean needsEmail(String email){
public boolean needsEmail(String email) {
return true;
}
public void PublishAction(DBObject object) throws Exception {