Programy Async Dispatch

OgloszeniaKlient/src/main/java/ogloszenia/klient_niskopoziomowy/Async1.java

+package ogloszenia.klient_niskopoziomowy;
+
+import jakarta.xml.ws.Dispatch;
+import jakarta.xml.ws.Response;
+import jakarta.xml.ws.Service;
+import ogloszenia.generated.OgloszeniaService;
+
+import javax.xml.namespace.QName;
+import javax.xml.transform.Source;
+import javax.xml.transform.stream.StreamSource;
+import java.io.StringReader;
+import java.util.concurrent.ExecutionException;
+
+public class Async1 {
+        static final String trescXML = """
+                <o:readOne xmlns:o="http://soap.ogloszenia/">
+                    <id>1</id>
+                </o:readOne>""";
+
+    public static void main(String[] args) {
+        System.out.println("Startujemy...");
+        OgloszeniaService service = new OgloszeniaService();
+
+        QName portName = OgloszeniaService.OgloszeniaPort;
+        Dispatch<Source> dispatch = service.createDispatch(portName, Source.class, Service.Mode.PAYLOAD);
+        System.out.println("Mam Dispatchera " + dispatch);
+
+        Utils utils = new Utils();
+        Source src = new StreamSource(new StringReader(trescXML));
+        System.out.println("Wysyłam zapytanie");
+        Response<Source> response = dispatch.invokeAsync(src);
+        System.out.println("Zapytanie zlecone");
+        System.out.println("lalalala, robię inne rzeczy");
+        boolean done = false;
+        do {
+            utils.czekaj(1000);
+            done = response.isDone();
+            System.out.println("Czy wynik już jest? " + done);
+        } while (!done);
+        try {
+            Source result = response.get();
+            System.out.println("Wykonuje to wątek nr " + Thread.currentThread().getId() + " " + Thread.currentThread().getName());
+            System.out.println("Mam wynik: " + result);
+            utils.wypiszTransformerem(result);
+            System.out.println("Gotowe");
+        } catch (InterruptedException e) {
+            System.err.println(e);
+        } catch (ExecutionException e) {
+            e.printStackTrace();
+        }
+    }
+}

OgloszeniaKlient/src/main/java/ogloszenia/klient_niskopoziomowy/Async2.java

+package ogloszenia.klient_niskopoziomowy;
+
+import jakarta.xml.ws.Dispatch;
+import jakarta.xml.ws.Response;
+import jakarta.xml.ws.Service;
+import ogloszenia.generated.OgloszeniaService;
+
+import javax.xml.namespace.QName;
+import javax.xml.transform.Source;
+import javax.xml.transform.stream.StreamSource;
+import java.io.StringReader;
+import java.util.concurrent.ExecutionException;
+
+public class Async2 {
+        static final String trescXML = """
+                <o:readOne xmlns:o="http://soap.ogloszenia/">
+                    <id>1</id>
+                </o:readOne>""";
+
+    public static void main(String[] args) {
+        System.out.println("Startujemy...");
+        OgloszeniaService service = new OgloszeniaService();
+
+        QName portName = OgloszeniaService.OgloszeniaPort;
+        Dispatch<Source> dispatch = service.createDispatch(portName, Source.class, Service.Mode.PAYLOAD);
+        System.out.println("Mam Dispatchera " + dispatch);
+
+        Utils utils = new Utils();
+        Source src = new StreamSource(new StringReader(trescXML));
+        System.out.println("Wysyłam zapytanie");
+        dispatch.invokeAsync(src, response -> {
+            try {
+                Source result = response.get();
+                System.out.println("Wykonuje to wątek nr " + Thread.currentThread().getId() + " " + Thread.currentThread().getName());
+                System.out.println("Mam wynik: " + result);
+                utils.wypiszTransformerem(result);
+                System.out.println("Gotowe");
+            } catch (InterruptedException e) {
+                System.err.println(e);
+            } catch (ExecutionException e) {
+                e.printStackTrace();
+            }
+        });
+        System.out.println("Zapytanie zlecone");
+        System.out.println("lalalala, robię inne rzeczy");
+        utils.czekaj(1000);
+        System.out.println("Koniec programu");
+    }
+}

OgloszeniaKlient/src/main/java/ogloszenia/klient_niskopoziomowy/Utils.java

@@ -28,4 +28,12 @@ public class Utils {
             throw new RuntimeException(e);
         }
     }
+
+    public void czekaj(long milis) {
+        try {
+            Thread.sleep(milis);
+        } catch (InterruptedException e) {
+            System.err.println(e);
+        }
+    }
 }