From d621dc3a1e32a20117d94ddb447da91ab5fbd5e2 Mon Sep 17 00:00:00 2001
From: taschi <nata.koch@yahoo.de>
Date: Sun, 22 Nov 2015 14:15:45 +0100
Subject: [PATCH] send Methode um n mailiges senden bis ack empfangen erweitert

---
 .../java/de/uniluebeck/mi/projmi6/hapi/HL7Sender.java  | 18 ++++++++----------
 1 file changed, 8 insertions(+), 10 deletions(-)

diff --git a/src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Sender.java b/src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Sender.java
index e9ff94e..cbebf12 100644
--- a/src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Sender.java
+++ b/src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Sender.java
@@ -8,6 +8,7 @@ import ca.uhn.hl7v2.app.HL7Service;
 import ca.uhn.hl7v2.app.Initiator;
 import ca.uhn.hl7v2.llp.LLPException;
 import ca.uhn.hl7v2.model.Message;
+import ca.uhn.hl7v2.model.v251.message.ACK;
 import ca.uhn.hl7v2.model.v251.message.ADT_A01;
 import ca.uhn.hl7v2.model.v251.segment.*;
 import ca.uhn.hl7v2.parser.Parser;
@@ -128,25 +129,22 @@ public class HL7Sender {
             Initiator initiator = connection.getInitiator ();
             Message response = null;
             try {
-                response = initiator.sendAndReceive ( adt );
+                while (! (response instanceof ACK)) {
+                    response = initiator.sendAndReceive ( adt );
+                    Thread.sleep ( 5000 );
+                }
             } catch (HL7Exception e) {
                 e.printStackTrace ();
             } catch (LLPException e) {
                 e.printStackTrace ();
             } catch (IOException e) {
                 e.printStackTrace ();
-            }
-    /*
-            String responseString = null;
-            try {
-                responseString = p.encode ( response );
-            } catch (HL7Exception e) {
+            } catch (InterruptedException e) {
                 e.printStackTrace ();
             }
-            System.out.println ( "Received response:\n" + responseString );
-            */
 
-               /*
+/*
+
         * Close the connection when you are done with it.
         */
             connection.close ();