Hl7 Simple Java Client

Hl7 Simple Java Client

  8:00 AM    mayuravaani

---

HL7 Sender Java Code

package hl7sender; import ca.uhn.hl7v2.DefaultHapiContext; import ca.uhn.hl7v2.HapiContext; import ca.uhn.hl7v2.app.Connection; import ca.uhn.hl7v2.app.Initiator; import ca.uhn.hl7v2.model.Message; import ca.uhn.hl7v2.parser.Parser; public class hl7sender {    public static void main(String[] args) { final int PORT_NUMBER = 9014; // In HAPI, almost all things revolve around a context object. HapiContext context = new DefaultHapiContext();       try {         String adtMessage = "MSH|^~\\&|NES|NINTENDO|TESTSYSTEM|TESTFACILITY|" + "20010101000000||ADT^A01|Q123456789T123456789X123456|P|2.3\r" + "EVN|A01|20010101000000|||^KOOPA^BOWSER\r" + "PID|1||123456789|0123456789^AA^^JP|BROS^MARIO||19850101000000|" + "M|||123 FAKE STREET^MARIO \\T\\ LUIGI BROS PLACE^TOADSTOOL" + "KINGDOM^NES^A1B2C3^JP^HOME^^1234|1234|(555)555-0123^HOME^JP:" + "1234567|||S|MSH|12345678|||||||0|||||N\r" + "NK1|1|PEACH^PRINCESS|SO|ANOTHER CASTLE^^TOADSTOOL KINGDOM" + "^NES^^JP|(123)555-1234|(123)555-2345|NOK\r" + "NK1|2|TOADSTOOL^PRINCESS|SO|YET ANOTHER CASTLE^^TOADSTOOL" + "KINGDOM^NES^^JP|(123)555-3456|(123)555-4567|EMC\r" + "PV1|1|O|ABCD^EFGH||||123456^DINO^YOSHI^^^^^^MSRM^CURRENT" + "^^^NEIGHBOURHOOD DR NBR|^DOG^DUCKHUNT^^^^^^^CURRENT||CRD||" + "|||||123456^DINO^YOSHI^^^^^^MSRM^CURRENT^^^NEIGHBOURHOOD DR" + " NBR|AO|0123456789|1|||||||||||||||||||MSH||A|||20010101000000\r" + "IN1|1|PAR^PARENT||||LUIGI\r"; // create a new MLLP client over the specified port. Connection connection = context.newClient("localhost", PORT_NUMBER, false); // The initiator which will be used to transmit our message. Initiator initiator = connection.getInitiator(); // send the created HL7 message over the connection established Parser parser = context.getPipeParser(); System.out.println("Sending message:" + "\n" + adtMessage); Message response = initiator.sendAndReceive(parser.parse(adtMessage)); // display the message response received from the remote party String responseString = parser.encode(response); System.out.println("Received response:\n" + responseString.replaceAll("\r", "\n"));         }         catch (Exception e) {            e.printStackTrace();         }    } }

HL7 Receiver Java Code

This main class is used to

package hl7receiver; import ca.uhn.hl7v2.DefaultHapiContext; import ca.uhn.hl7v2.HapiContext; import ca.uhn.hl7v2.app.HL7Service; import ca.uhn.hl7v2.parser.Parser; import ca.uhn.hl7v2.parser.PipeParser; public class hl7receiver {     public static void main(String args[]) {         final int PORT_NUMBER = 9014;         //In HAPI,almost all things revolve around a context object         HapiContext context = new DefaultHapiContext();         try {             Parser parser = new PipeParser();             HL7Service ourHl7Server =                   context.newServer(PORT_NUMBER, false);             // You can set up routing rules for your HL7 listener by extending the AppRoutingData class             ourHl7Server.registerApplication(new     RegisterEventRouter(), new ourSimpleApplication());             ourHl7Server.setShutdownTimeout(10000);             ourHl7Server.startAndWait();         } catch (Exception e) {             e.printStackTrace();         }     } }

Simple Application class that is used to receive the message and create and send the acknowledgement

package hl7receiver; import ca.uhn.hl7v2.HL7Exception; import ca.uhn.hl7v2.model.Message; import ca.uhn.hl7v2.parser.PipeParser; import ca.uhn.hl7v2.protocol.ReceivingApplication; import ca.uhn.hl7v2.protocol.ReceivingApplicationException; import java.io.IOException; import java.util.Map; public class ourSimpleApplication implements ReceivingApplication {     PipeParser pipeParser = new PipeParser();     public Message processMessage(Message message, Map map) throws  ReceivingApplicationException, HL7Exception {         System.out.println("Received Message\n" + pipeParser.encode(message));         Message response = null;         try {             response = message.generateACK();             System.out.println("Sent Response\n" + pipeParser.encode(response));         } catch (IOException e) {             e.printStackTrace();         }         return response;     }     public boolean canProcess(Message message) {         return true;     } }

Event Router class that is used to rout the message to the appropriate versions and types.

package hl7receiver; import ca.uhn.hl7v2.protocol.ApplicationRouter; public class RegisterEventRouter implements ApplicationRouter.AppRoutingData {     public String getMessageType() {         return "*";     }     public String getTriggerEvent() {         return "*";     }     public String getProcessingId() {         return "*";     }     public String getVersion() {         return "*";     } }