misc/env/src/main/java/org/onap/aaf/misc/env/jaxb/JAXBObjectifier.java

   1 /**\r
   2  * ============LICENSE_START====================================================\r
   3  * org.onap.aaf\r
   4  * ===========================================================================\r
   5  * Copyright (c) 2018 AT&T Intellectual Property. All rights reserved.\r
   6  * ===========================================================================\r
   7  * Licensed under the Apache License, Version 2.0 (the "License");\r
   8  * you may not use this file except in compliance with the License.\r
   9  * You may obtain a copy of the License at\r
  10  * \r
  11  *      http://www.apache.org/licenses/LICENSE-2.0\r
  12  * \r
  13  * Unless required by applicable law or agreed to in writing, software\r
  14  * distributed under the License is distributed on an "AS IS" BASIS,\r
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
  16  * See the License for the specific language governing permissions and\r
  17  * limitations under the License.\r
  18  * ============LICENSE_END====================================================\r
  19  *\r
  20  */\r
  21 \r
  22 package org.onap.aaf.misc.env.jaxb;\r
  23 \r
  24 import java.io.InputStream;\r
  25 import java.io.Reader;\r
  26 \r
  27 import javax.xml.bind.JAXBException;\r
  28 import javax.xml.validation.Schema;\r
  29 \r
  30 import org.onap.aaf.misc.env.APIException;\r
  31 import org.onap.aaf.misc.env.Env;\r
  32 import org.onap.aaf.misc.env.TimeTaken;\r
  33 import org.onap.aaf.misc.env.old.IOObjectifier;\r
  34 \r
  35 /**\r
  36  * Allow Extended IO interface usage without muddying up the Stringifier Interface\r
  37  */\r
  38 public class JAXBObjectifier<T> implements IOObjectifier<T> {\r
  39         private JAXBumar jumar;\r
  40 \r
  41         public JAXBObjectifier(Schema schema, Class<?>... classes) throws APIException {\r
  42                 try {\r
  43                         jumar = new JAXBumar(schema, classes);\r
  44                 } catch (JAXBException e) {\r
  45                         throw new APIException(e);\r
  46                 }\r
  47         }\r
  48 \r
  49         public JAXBObjectifier(Class<?>... classes) throws APIException {\r
  50                 try {\r
  51                         jumar = new JAXBumar(classes);\r
  52                 } catch (JAXBException e) {\r
  53                         throw new APIException(e);\r
  54                 }\r
  55         }\r
  56         \r
  57     // package on purpose\r
  58         JAXBObjectifier(JAXBumar jumar) {\r
  59                 this.jumar = jumar;\r
  60         }\r
  61 \r
  62         @SuppressWarnings("unchecked")\r
  63         // @Override\r
  64         public T objectify(Env env, String input) throws APIException {\r
  65                 TimeTaken tt = env.start("JAXB Unmarshal", Env.XML);\r
  66                 try {\r
  67                         tt.size(input.length());\r
  68                         return (T)jumar.unmarshal(env.debug(), input);\r
  69                 } catch (JAXBException e) {\r
  70                         throw new APIException(e);\r
  71                 } finally {\r
  72                         tt.done();\r
  73                 }\r
  74         }\r
  75 \r
  76         @SuppressWarnings("unchecked")\r
  77         // @Override\r
  78         public T objectify(Env env, Reader rdr) throws APIException {\r
  79                 //TODO create a Reader that Counts?\r
  80                 TimeTaken tt = env.start("JAXB Unmarshal", Env.XML);\r
  81                 try {\r
  82                         return (T)jumar.unmarshal(env.debug(), rdr);\r
  83                 } catch (JAXBException e) {\r
  84                         throw new APIException(e);\r
  85                 } finally {\r
  86                         tt.done();\r
  87                 }\r
  88         }\r
  89 \r
  90 \r
  91         @SuppressWarnings("unchecked")\r
  92         // @Override\r
  93         public T objectify(Env env, InputStream is) throws APIException {\r
  94                 //TODO create a Reader that Counts?\r
  95                 TimeTaken tt = env.start("JAXB Unmarshal", Env.XML);\r
  96                 try {\r
  97                         return (T)jumar.unmarshal(env.debug(), is);\r
  98                 } catch (JAXBException e) {\r
  99                         throw new APIException(e);\r
 100                 } finally {\r
 101                         tt.done();\r
 102                 }\r
 103         }\r
 104 \r
 105 \r
 106         public void servicePrestart(Env env) throws APIException {\r
 107         }\r
 108 \r
 109         public void threadPrestart(Env env) throws APIException {\r
 110         }\r
 111 \r
 112         // // @Override\r
 113         public void refresh(Env env) throws APIException {\r
 114         }\r
 115 \r
 116         // // @Override\r
 117         public void threadDestroy(Env env) throws APIException {\r
 118         }\r
 119 \r
 120         // // @Override\r
 121         public void serviceDestroy(Env env) throws APIException {\r
 122         }\r
 123 \r
 124 \r
 125         @SuppressWarnings("unchecked")\r
 126         public T newInstance() throws APIException {\r
 127                 try {\r
 128                         return (T)jumar.newInstance();\r
 129                 } catch (Exception e) {\r
 130                         throw new APIException(e);\r
 131                 }\r
 132         }\r
 133 \r
 134 }\r
 135 \r