no message

src/_VisualDVM/Passes/All/Email.java

@@ -1,11 +1,12 @@
 package _VisualDVM.Passes.All;
 import _VisualDVM.Passes.Server.ComponentsRepositoryPass_OLD;
+import _VisualDVM.Passes.Server.ComponentsServerPass;
 import _VisualDVM.Repository.EmailMessage;
 import _VisualDVM.Repository.Server.ServerCode;
 import _VisualDVM.Repository.Server.ServerExchangeUnit_2021;
 
 import java.util.Vector;
-public class Email extends ComponentsRepositoryPass_OLD<EmailMessage> {
+public class Email extends ComponentsServerPass<EmailMessage> {
     Vector<String> recipients;
     @Override
     protected boolean canStart(Object... args) throws Exception {
@@ -28,17 +29,8 @@ public class Email extends ComponentsRepositoryPass_OLD<EmailMessage> {
         return false;
     }
     @Override
-    protected int getTimeout() {
-        return 0;
-    }
-    @Override
-    protected void ServerAction() throws Exception {
-        int i = 0;
-        for (String address : recipients) {
-            ShowProgress(recipients.size(), i, true);
-            Command(new ServerExchangeUnit_2021(ServerCode.Email, address, target));
-            ++i;
-        }
+    protected void body() throws Exception {
+        SendRequest(ServerCode.EmailBroadcast, String.join("\n",recipients), target);
     }
 }
 

src/_VisualDVM/Repository/RepositoryServer.java

@@ -224,6 +224,9 @@ public abstract class RepositoryServer<D extends Database> {
                                     Email((EmailMessage) request.object, request.arg);
                                     response = new ServerExchangeUnit_2021(ServerCode.OK);
                                     break;
+                                case EmailBroadcast:
+                                    EmailBroadcast();
+                                    break;
                                 //</editor-fold>
                                 //<editor-fold desc="Главная база данных">
                                 case CheckObjectExistense:
@@ -321,6 +324,15 @@ public abstract class RepositoryServer<D extends Database> {
             }
         }
     }
+    private void EmailBroadcast() throws Exception{
+        String [] packed = request.arg.split("\n");
+        for (String address: packed){
+            if (!address.isEmpty()){
+                Email((EmailMessage) request.object, address);
+            }
+        }
+        response = new ServerExchangeUnit_2021(ServerCode.OK);
+    }
     //--
     protected Database getDefaultDatabase() {
         return db;

src/_VisualDVM/Repository/Server/ServerCode.java

@@ -15,6 +15,7 @@ public enum ServerCode {
     AppendBugReportTextField,
     //-
     Email,
+    EmailBroadcast,
     ReceiveAllArchives,
     //-
     DownloadTest,
@@ -111,6 +112,8 @@ public enum ServerCode {
                 return "Получение журнала изменений компонента с сервера";
             case CheckURLRegistered:
                 return "Проверка регистрации машины на сервере";
+            case EmailBroadcast:
+                return "Рассылка";
             default:
                 return this.toString();
         }