JAXB Marshall and UnMarshall Example (Include post request to REST API)

Pom.xml:

<dependency>
 <groupId>javax.xml.bind</groupId>
 <artifactId>jaxb-api</artifactId>
 <version>2.1</version>
</dependency>
<dependency>
 <groupId>com.sun.xml.bind</groupId>
 <artifactId>jaxb-impl</artifactId>
 <version>2.1</version>
</dependency>

Code:

public final String MESSAGE_URL = "http://test.com/messageservice/send";

public boolean sendMessage(Message message) {
 
       URL url = null;
       try {
           url = new URL(SS_URL);
       } catch (MalformedURLException e1) {
           e1.printStackTrace();
       }

       try {

           System.out.println("Start converting message to XML.");

           // Marshall
       
           JAXBContext jaxbContext = JAXBContext.newInstance(Message.class);
           Marshaller jaxbMarshaller = jaxbContext.createMarshaller();
 
           // output pretty printed
           jaxbMarshaller.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, true);
 
           ByteOutputStream out = new ByteOutputStream();
           jaxbMarshaller.marshal(message, out);

           String msg = new String(out.getBytes(),"utf-8");

           System.out.println("Finish converting message to XML.");

           System.out.println(msg);
         
           HttpURLConnection connect = (HttpURLConnection) url.openConnection();
           connect.setRequestMethod("POST");
           connect.setDoOutput(true);
           connect.setRequestProperty("Content-Type", "text/xml");
           connect.setAllowUserInteraction(false);
         
           // send query

           OutputStream os = connect.getOutputStream();
           jaxbMarshaller.marshal(message, os);
           os.flush();
           os.close();

           if (connect.getResponseCode() != 200) {
               System.out.println("Message sent failed.");
               return false;
           }

           System.out.println("Message sent.");

           System.out.println("Result:");
         
           // Unmarshall
       
             Unmarshaller jaxbUnmarshaller = jaxbContext.createUnmarshaller();
           Message result = (N2NMessage) jaxbUnmarshaller.unmarshal(connect.getInputStream());
           System.out.println("Sent Message Id: " + result.getMessageID());
         
         
           return true;
         
       } catch (Exception e) {
           e.printStackTrace();
           return false;
       }
}

To print the full response. We can try:

BufferedReader bis = new BufferedReader(new InputStreamReader(
                   connect.getInputStream()));
String line;

while ((line = bis.readLine()) != null) {
 System.out.println(line);
}

One method that wrote for the full service:

protected Object sendRequest(String URL, boolean auth, Object obj, Class... marshallClasses){

     
       URL url = null;
       try {
           url = new URL(SS_URL);
       } catch (MalformedURLException e1) {
           e1.printStackTrace();
       }
     
       logger.info("Start converting message to XML.");

       try {
           JAXBContext jaxbContext = JAXBContext.newInstance(marshallClasses);
           Marshaller jaxbMarshaller = jaxbContext.createMarshaller();
   
           // output pretty printed
           jaxbMarshaller.setProperty(Marshaller.JAXB_FORMATTED_OUTPUT, true);
   
           ByteOutputStream out = new ByteOutputStream();
           jaxbMarshaller.marshal(obj, out);

           String msg = new String(out.getBytes(),"utf-8");

           logger.info("Finish converting message to XML.");

           logger.info("Request: ");
           logger.info("==================================================================================================================");
           logger.info(msg);
         
           HttpURLConnection connect = (HttpURLConnection) url
                   .openConnection();
           connect.setRequestMethod("POST");
           connect.setDoOutput(true);
           connect.setRequestProperty("Content-Type", "text/xml");
           if(auth){
               connect.setRequestProperty("Authorization", "Basic c3VyZXNjcmlwdHNOMk46M2cjNDNOZk5Kc2Ep");
           }
           connect.setAllowUserInteraction(false);
           // send query

           OutputStream os = connect.getOutputStream();
           jaxbMarshaller.marshal(obj, os);
           os.flush();
           os.close();
           logger.info("==================================================================================================================");
         
           if (connect.getResponseCode() != 200) {
               logger.info("Message sent failed.");
               return null;
           }

           logger.info("Message sent.");
           logger.info("Response:");
           logger.info("==================================================================================================================");
         
           InputStream result = connect.getInputStream();
         
           byte[] tmp = IOUtils.toByteArray(result);
           InputStream newInput = new ByteArrayInputStream(tmp);
           BufferedReader bis = new BufferedReader(new InputStreamReader(newInput));
           String line;

           while ((line = bis.readLine()) != null) {
               logger.info(line);
           }
           logger.info("==================================================================================================================");
         
           Unmarshaller jaxbUnmarshaller = jaxbContext.createUnmarshaller();
           Object resultObj = jaxbUnmarshaller.unmarshal( new ByteArrayInputStream(tmp));
         
           return resultObj;
         
       }catch (Exception e) {
           logger.error(e.getMessage(), e);
           return null;
       }
     
   }