send message angepasst - auf unsere Nachricht umgeschrieben sowie ip und port eingetragen

src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Sender.java

@@ -14,6 +14,7 @@ import ca.uhn.hl7v2.parser.Parser;
 import ca.uhn.hl7v2.parser.PipeParser;
 import ca.uhn.hl7v2.validation.ValidationContext;
 import ca.uhn.hl7v2.validation.impl.ValidationContextFactory;
+import de.uniluebeck.mi.projmi6.Main;
 import de.uniluebeck.mi.projmi6.model.Diagnose;
 import de.uniluebeck.mi.projmi6.model.Fall;
 import de.uniluebeck.mi.projmi6.model.Patient;
@@ -103,10 +104,11 @@ public class HL7Sender {
          * The following section of code establishes a server listening
          * on port 1011 for new connections, and then "handles" them by
          */
-        int port = 1011; // The port to listen on
-        boolean useTls = false; // Don't use TLS/SSL
-        HapiContext context = new DefaultHapiContext();
-        HL7Service server = context.newServer(port, useTls);
+        if(message instanceof ADT_A01) {
+            ADT_A01 adt = (ADT_A01) message;
+            int port = Main.OPS_PORT;
+            HapiContext context = new DefaultHapiContext ();
+            HL7Service server = context.newServer ( port, false );
 
 
   /*
@@ -114,85 +116,43 @@ public class HL7Sender {
         * server and send messages to it.
         */
 
-        // A connection object represents a socket attached to an HL7 server
-        Connection connection = null;
-        try {
-            connection = context.newClient("localhost", port, useTls);
-        } catch (HL7Exception e) {
-            e.printStackTrace();
-        }
-
-        // Create a message to send
-        String msg = "MSH|^~\\&|HIS|RIH|EKG|EKG|199904140038||ADT^A01|12345|P|2.2\r"
-                + "PID|0001|00009874|00001122|A00977|SMITH^JOHN^M|MOM|19581119|F|NOTREAL^LINDA^M|C|564 SPRING ST^^NEEDHAM^MA^02494^US|0002|(818)565-1551|(425)828-3344|E|S|C|0000444444|252-00-4414||||SA|||SA||||NONE|V1|0001|I|D.ER^50A^M110^01|ER|P00055|11B^M011^02|070615^BATMAN^GEORGE^L|555888^NOTREAL^BOB^K^DR^MD|777889^NOTREAL^SAM^T^DR^MD^PHD|ER|D.WT^1A^M010^01|||ER|AMB|02|070615^NOTREAL^BILL^L|ER|000001916994|D||||||||||||||||GDD|WA|NORM|02|O|02|E.IN^02D^M090^01|E.IN^01D^M080^01|199904072124|199904101200|199904101200||||5555112333|||666097^NOTREAL^MANNY^P\r"
-                + "NK1|0222555|NOTREAL^JAMES^R|FA|STREET^OTHER STREET^CITY^ST^55566|(222)111-3333|(888)999-0000|||||||ORGANIZATION\r"
-                + "PV1|0001|I|D.ER^1F^M950^01|ER|P000998|11B^M011^02|070615^BATMAN^GEORGE^L|555888^OKNEL^BOB^K^DR^MD|777889^NOTREAL^SAM^T^DR^MD^PHD|ER|D.WT^1A^M010^01|||ER|AMB|02|070615^VOICE^BILL^L|ER|000001916994|D||||||||||||||||GDD|WA|NORM|02|O|02|E.IN^02D^M090^01|E.IN^01D^M080^01|199904072124|199904101200|||||5555112333|||666097^DNOTREAL^MANNY^P\r"
-                + "PV2|||0112^TESTING|55555^PATIENT IS NORMAL|NONE|||19990225|19990226|1|1|TESTING|555888^NOTREAL^BOB^K^DR^MD||||||||||PROD^003^099|02|ER||NONE|19990225|19990223|19990316|NONE\r"
-                + "AL1||SEV|001^POLLEN\r"
-                + "GT1||0222PL|NOTREAL^BOB^B||STREET^OTHER STREET^CITY^ST^77787|(444)999-3333|(222)777-5555||||MO|111-33-5555||||NOTREAL GILL N|STREET^OTHER STREET^CITY^ST^99999|(111)222-3333\r"
-                + "IN1||022254P|4558PD|BLUE CROSS|STREET^OTHER STREET^CITY^ST^00990||(333)333-6666||221K|LENIX|||19980515|19990515|||PATIENT01 TEST D||||||||||||||||||02LL|022LP554";
-        Parser p = context.getPipeParser();
-        Message adt = null;
-        try {
-            adt = p.parse(msg);
-        } catch (HL7Exception e) {
-            e.printStackTrace();
-        }
-
-        // The initiator is used to transmit unsolicited messages
-        Initiator initiator = connection.getInitiator();
-        Message response = null;
-        try {
-            response = initiator.sendAndReceive(adt);
-        } 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) {
-            e.printStackTrace();
-        }
-        System.out.println("Received response:\n" + responseString);
+            // A connection object represents a socket attached to an HL7 server
+            Connection connection = null;
+            try {
+                connection = context.newClient ( Main.OPS_IP, port, false);
+            } catch (HL7Exception e) {
+                e.printStackTrace ();
+            }
 
-               /*
-        * MSH|^~\&|||||20070218200627.515-0500||ACK|54|P|2.2 MSA|AA|12345
-        */
+            // The initiator is used to transmit unsolicited messages
+            Initiator initiator = connection.getInitiator ();
+            Message response = null;
+            try {
+                response = initiator.sendAndReceive ( adt );
+            } catch (HL7Exception e) {
+                e.printStackTrace ();
+            } catch (LLPException e) {
+                e.printStackTrace ();
+            } catch (IOException e) {
+                e.printStackTrace ();
+            }
 
-               /*
-        * If you want to send another message to the same destination, it's fine
-        * to ask the context again for a client to attach to the same host/port.
-        * The context will be smart about it and return the same (already
-        * connected) client Connection instance, assuming it hasn't been closed.
-        */
-        try {
-            connection = context.newClient("localhost", port, useTls);
-        } catch (HL7Exception e) {
-            e.printStackTrace();
-        }
-        initiator = connection.getInitiator();
-        try {
-            response = initiator.sendAndReceive(adt);
-        } 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) {
+                e.printStackTrace ();
+            }
+            System.out.println ( "Received response:\n" + responseString );
 
                /*
         * Close the connection when you are done with it.
         */
-        connection.close();
+            connection.close ();
 
-        // Stop the receiving server and client
-        server.stopAndWait();
+            // Stop the receiving server and client
+            server.stop ();
+        }
 
     }