Hi - thanks for the confirmatyion. You may want to update the client code a bit : - remove HttpConduit config, unless PDF is really large - set client.accept to the expected media type - replace byte[] with DataHandler - this may be better in terms of performance - may need to verify - remove a 2nd class parameter in client.post
cheers, Sergey On Thu, Sep 23, 2010 at 9:38 PM, Reddy, Rama <[email protected]> wrote: > Hi Sergey, > > > > Thanks for pointing out those examples. I tried all possible ways to avoid > that InputStream unmarshalling exception and as part of that I thought the > service consumption is not accepting that format and hence I used the > wildcard. > > > > Currently I got it working looking at your test file. > > > > > > Following is the solution: > > > > My CustomRequest object: > > ================= > > @XmlRootElement(name = "pdfUploadRequest") > > @XmlType(name = "PDFUploadRequest", propOrder = { > > "name", > > "fileBytes"}) > > *public* *class* PDFUploadRequest { > > > > *private* String name; > > *private* *byte*[] fileBytes; > > > > @XmlElement(required = *true*) > > *public* String getName() { > > *return* name; > > } > > *public* *void* setName(String value) { > > *this*.name = value; > > } > > > > @XmlElement(required = *false*) > > @XmlMimeType("application/octet-stream") > > *public* *byte*[] getFileBytes() { > > *return* fileBytes; > > } > > *public* *void* setFileBytes(*byte*[] value) { > > *this*.fileBytes = value; > > } > > } > > > > My Service interface… > > ===================== > > *public* *interface* PDFUploadService { > > > > @POST > > @Path("/upload") > > @Consumes("multipart/related") > > *public* *void* uploadPDFTickets(PDFUploadRequest > pdfUploadRequest); > > } > > > > My cxf-bean config > > ================== > > <bean id=*"pdfUploadService"* class=* > "com.custom.PDFUploadServiceImpl"* /> > > <jaxrs:server id=*"pdfUploadServices"* address=*"/"*> > > <jaxrs:properties> > > <entry key=*"mtom-enabled"* value=*"true"*/> > > </jaxrs:properties> > > <jaxrs:serviceBeans> > > <ref bean=*"pdfUploadService"* /> > > </jaxrs:serviceBeans> > > </jaxrs:server> > > > > My Client call.. > > ================ > > *public* *class* PDFUploadClient { > > *public* *static* *void* main(String[] args) *throws* Exception { > > String address = "http://localhost:8080/myapp/upload";; > > JAXRSClientFactoryBean bean = *new* JAXRSClientFactoryBean(); > > bean.setAddress(address); > > // ensure XOP is supported > > bean.setProperties(Collections.*singletonMap* > (org.apache.cxf.message.Message.*MTOM_ENABLED*,(Object)"true")); > > WebClient client = bean.createWebClient(); > > client.type("multipart/related").accept("multipart/related"); > > > > // for debugging > > HTTPConduit conduit = (HTTPConduit) WebClient.*getConfig* > (client).getConduit(); > > conduit.getClient().setReceiveTimeout(1000000); > > conduit.getClient().setConnectionTimeout(1000000); > > > > File inputFile = *new* File("myFile.pdf"); > > InputStream inputStream = *new* FileInputStream(inputFile); > > *byte*[] fileBytes = IOUtils.*readBytesFromStream*(inputStream); > > > > PDFUploadRequest uploadRequest = *new* PDFUploadRequest(); > > uploadRequest.setFileBytes(fileBytes); > > > > client.post(uploadRequest, PDFUploadRequest.*class*); > > } > > } > > > > I was able to transfer the file. > > > > Thanks for your help. > > > > Thanks > > Rama > > > > > > > > *From:* Sergey Beryozkin [mailto:[email protected]] > *Sent:* Thursday, September 23, 2010 1:56 AM > *To:* Reddy, Rama > *Cc:* [email protected]; Pydipati, Karuna > > *Subject:* Re: Looking for samples on sending binary files in a REST > service using Base64 encoding.. > > > > Hi > > I'm not sure why you've decided to go with a wildcard media type. Have a > look please at my last/previous response and see if you can make it work. > See JAXRSMultipartTest and MultipartServer in systests/jaxrs for an example > if you get stuck... > > cheers, Sergey > > On Thu, Sep 23, 2010 at 12:04 AM, Reddy, Rama <[email protected]> > wrote: > > Hi Sergey, > > I somehow figured that JAXB bindings are missing in my CustomRequest object > but now I am ending up in following issue. It is not able to create a > instance of InputStream. I chose wild card type, so that everything will be > accepted? Will that cause any issue? > > Encoding: ISO-8859-1 > Content-Type: */* > Headers: {content-type=[*/*], connection=[keep-alive], host=[ > ilog.srwd00.com], content-length=[59], user-agent=[Apache CXF 2.2.3], > Content-Type=[*/*], Accept=[*/*], pragma=[no-cache], Cache-Contr > ol=[no-cache]} > Payload: {"PDFUploadRequest":{"ticketSeatId":12345,"fileStream":""}} > -------------------------------------- > 2010-09-22 16:00:09,645 ERROR [STDERR] Sep 22, 2010 4:00:09 PM > org.apache.cxf.jaxrs.provider.AbstractJAXBProvider handleJAXBException > WARNING: javax.xml.bind.UnmarshalException > - with linked exception: > [javax.xml.bind.UnmarshalException: Unable to create an instance of > java.io.InputStream > - with linked exception: > [java.lang.InstantiationException]] > at > com.sun.xml.bind.v2.runtime.unmarshaller.UnmarshallerImpl.handleStreamException(UnmarshallerImpl.java:421) > at > com.sun.xml.bind.v2.runtime.unmarshaller.UnmarshallerImpl.unmarshal0(UnmarshallerImpl.java:360) > at > com.sun.xml.bind.v2.runtime.unmarshaller.UnmarshallerImpl.unmarshal(UnmarshallerImpl.java:330) > at > org.apache.cxf.jaxrs.provider.JSONProvider.readFrom(JSONProvider.java:156) > at > org.apache.cxf.jaxrs.utils.JAXRSUtils.readFromMessageBody(JAXRSUtils.java:861) > at > org.apache.cxf.jaxrs.utils.JAXRSUtils.processParameter(JAXRSUtils.java:494) > at > org.apache.cxf.jaxrs.utils.JAXRSUtils.processParameters(JAXRSUtils.java:459) > at > org.apache.cxf.jaxrs.interceptor.JAXRSInInterceptor.processRequest(JAXRSInInterceptor.java:204) > at > org.apache.cxf.jaxrs.interceptor.JAXRSInInterceptor.handleMessage(JAXRSInInterceptor.java:65) > > at > org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:236) > > at > org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInitiationObserver.java:104) > at > org.apache.cxf.transport.servlet.ServletDestination.invoke(ServletDestination.java:99) > at > org.apache.cxf.transport.servlet.ServletController.invokeDestination(ServletController.java:452) > at > org.apache.cxf.transport.servlet.ServletController.invoke(ServletController.java:159) > at > org.apache.cxf.transport.servlet.AbstractCXFServlet.invoke(AbstractCXFServlet.java:220) > at > org.apache.cxf.transport.servlet.AbstractCXFServlet.doPost(AbstractCXFServlet.java:153) > at javax.servlet.http.HttpServlet.service(HttpServlet.java:710) > at > org.apache.cxf.transport.servlet.AbstractCXFServlet.service(AbstractCXFServlet.java:211) > at > org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:290) > at > org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206) > at > org.jboss.web.tomcat.filters.ReplyHeaderFilter.doFilter(ReplyHeaderFilter.java:96) > at > org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:235) > at > org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206) > at > org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:230) > at > org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:175) > at > org.jboss.web.tomcat.security.SecurityAssociationValve.invoke(SecurityAssociationValve.java:179) > at > org.jboss.web.tomcat.security.JaccContextValve.invoke(JaccContextValve.java:84) > at > org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:127) > at > org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:102) > at > org.jboss.web.tomcat.service.jca.CachedConnectionValve.invoke(CachedConnectionValve.java:157) > at > org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:109) > at > org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:262) > at org.apache.coyote.ajp.AjpProcessor.process(AjpProcessor.java:437) > at > org.apache.coyote.ajp.AjpProtocol$AjpConnectionHandler.process(AjpProtocol.java:366) > at > org.apache.tomcat.util.net.JIoEndpoint$Worker.run(JIoEndpoint.java:446) > at java.lang.Thread.run(Thread.java:619) > Caused by: javax.xml.bind.UnmarshalException: Unable to create an instance > of java.io.InputStream > - with linked exception: > > Am I missing something here.. > > Thanks > Rama > > > -----Original Message----- > From: Reddy, Rama > Sent: Wednesday, September 22, 2010 1:23 PM > To: [email protected]; '[email protected]' > Cc: Pydipati, Karuna > Subject: RE: Looking for samples on sending binary files in a REST service > using Base64 encoding.. > > Hi Sergey, > > Thanks for a prompt response. I tried using that but I am seeing this > exception now: > > Sep 22, 2010 1:08:10 PM org.apache.cxf.jaxrs.client.AbstractClient > reportNoMessageHandler > SEVERE: .No message body writer found for class : class > com.custom.PDFUploadRequest. > Sep 22, 2010 1:08:10 PM org.apache.cxf.phase.PhaseInterceptorChain > doIntercept > WARNING: Interceptor has thrown exception, unwinding now > org.apache.cxf.interceptor.Fault > at > org.apache.cxf.jaxrs.client.WebClient$BodyWriter.handleMessage(WebClient.java:588) > at > org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:236) > at > org.apache.cxf.jaxrs.client.WebClient.doChainedInvocation(WebClient.java:529) > at > org.apache.cxf.jaxrs.client.WebClient.doInvoke(WebClient.java:510) > at org.apache.cxf.jaxrs.client.WebClient.invoke(WebClient.java:286) > at org.apache.cxf.jaxrs.client.WebClient.post(WebClient.java:303) > at PDFUploadClient.main(PDFUploadClient.java:37) > Caused by: javax.ws.rs.WebApplicationException > at > org.apache.cxf.jaxrs.client.AbstractClient.reportNoMessageHandler(AbstractClient.java:450) > at > org.apache.cxf.jaxrs.client.AbstractClient.writeBody(AbstractClient.java:365) > at > org.apache.cxf.jaxrs.client.WebClient$BodyWriter.handleMessage(WebClient.java:585) > ... 6 more > Exception in thread "main" javax.ws.rs.WebApplicationException > at org.apache.cxf.jaxrs.client.WebClient.invoke(WebClient.java:289) > at org.apache.cxf.jaxrs.client.WebClient.post(WebClient.java:303) > at PDFUploadClient.main(PDFUploadClient.java:37) > > > Here is the client code: > ------------------------------ > import org.apache.cxf.jaxrs.client.JAXRSClientFactoryBean; > import org.apache.cxf.jaxrs.client.WebClient; > import org.apache.cxf.transport.http.HTTPConduit; > > public class PDFUploadClient { > public static void main(String[] args) throws Exception { > > String address = "http://localhost:8080/upload";; > > JAXRSClientFactoryBean bean = new JAXRSClientFactoryBean(); > bean.setAddress(address); > // ensure XOP is supported > > > bean.setProperties(Collections.singletonMap(org.apache.cxf.message.Message.MTOM_ENABLED,(Object)"true")); > WebClient client = bean.createWebClient(); > client.type("multipart/related").accept("multipart/related"); > > // for debugging > > HTTPConduit conduit = (HTTPConduit) > WebClient.getConfig(client).getConduit(); > > conduit.getClient().setReceiveTimeout(1000000); > conduit.getClient().setConnectionTimeout(1000000); > > File inputFile = new File("X:\\test.pdf"); > InputStream seatFile = new FileInputStream(inputFile); > > PDFUploadRequest uploadRequest = new PDFUploadRequest(); > uploadRequest.setTicketSeatId(12345L); > uploadRequest.setSeatPdfFile(seatFile); > > client.post(uploadRequest, PDFUploadRequest.class); > } > } > > Here is my cxf-bean config: > <bean id="pdfUploadService" class="com.service.PDFUploadServiceImpl" /> > <jaxrs:server id="pdfUploadServices" address="/"> > <jaxrs:properties> > <entry key="mtom-enabled" value="true"/> > </jaxrs:properties> > <jaxrs:serviceBeans> > <ref bean="pdfUploadService" /> > </jaxrs:serviceBeans> > </jaxrs:server> > > Here is my Service interface: > @POST > @Path("/upload") > @Consumes("multipart/related") > public void uploadPDFTickets(PDFUploadRequest pdfUploadRequest); > > Here is my service implementation: > public void uploadPDFTickets(PDFUploadRequest pdfUploadRequest) { > log.info("uploadPDFTickets - pdfUploadRequest : " + > pdfUploadRequest); > if(pdfUploadRequest != null) { > try { > InputStream inputStream = > pdfUploadRequest.getSeatPdfFile(); > String fileName = > "Resp_"+System.currentTimeMillis()+".pdf"; > File outputFile = new > File("X:\\nas\\rama\\transformed\\"+fileName); > > OutputStream out=new > FileOutputStream(outputFile); > byte buf[]=new byte[1024]; > int len; > while((len=inputStream.read(buf))>0) { > out.write(buf,0,len); > } > out.close(); > > log.info("Succesfully created a file " + > fileName); > > } catch(Exception e) { > log.error("Exception while processing the > attachment in REST service " , e); > } > } > } > > > Am I missing something here? > > > > > > > > > > > > > > > > > > > > > > > > > > > -----Original Message----- > From: Sergey Beryozkin [mailto:[email protected]] > Sent: Friday, September 17, 2010 11:31 AM > To: [email protected] > Subject: Re: Looking for samples on sending binary files in a REST service > using Base64 encoding.. > > Hi > > It appears you'd actually like to have JAXB based XOP support on the server > side. > So have a @MediaType(multipart/related) on the server side as well as set a > contextual property "mtom.enabled" in jaxrs:server, and here's a test > showing how to sent it all it on the client side : > > @Test > public void testXopWebClient() throws Exception { > String address = "http://localhost:"; + PORT + "/bookstore/xop"; > JAXRSClientFactoryBean bean = new JAXRSClientFactoryBean(); > bean.setAddress(address); > > > // ensure XOP is supported > > > bean.setProperties(Collections.singletonMap(org.apache.cxf.message.Message.MTOM_ENABLED, > > (Object)"true")); > WebClient client = bean.createWebClient(); > client.type("multipart/related").accept("multipart/related"); > > // for debugging > > HTTPConduit conduit = WebClient.getConfig(client).getHttpConduit(); > conduit.getClient().setReceiveTimeout(1000000); > conduit.getClient().setConnectionTimeout(1000000); > > > // populate your CustomObject here as needed > XopType xop = new XopType(); > xop.setName("xopName"); > InputStream is = > > > getClass().getResourceAsStream("/org/apache/cxf/systest/jaxrs/resources/book.xsd"); > byte[] data = IOUtils.readBytesFromStream(is); > xop.setAttachinfo(new DataHandler(new ByteArrayDataSource(data, > "application/octet-stream"))); > > String bookXsd = > IOUtils.readStringFromStream(getClass().getResourceAsStream( > "/org/apache/cxf/systest/jaxrs/resources/book.xsd")); > xop.setAttachinfo2(bookXsd.getBytes()); > > > client.post(xop, XopType.class); > > > } > > You probably want to have InputStream instead of File... > > > give it a try please > Sergey > > > > On Thu, Sep 16, 2010 at 10:25 PM, Reddy, Rama <[email protected]> > wrote: > > > Hi, > > > > > > > > We have a requirement in out project to create a REST service with custom > > request object and sending pdf attachment[s) as a property in that custom > > request entity. Are there any existing samples around this? > > > > > > > > As of now, I am using multipartbody to get list of attachments and > > specifically recognize my attachment from that list, is there a simple > way > > to get this into a Custom request entity: > > > > > > > > Current implementation is something like this: > > > > > > public interface PDFUploadService { > > @POST > > @Path("/multipart") > > @Consumes(MediaType.MULTIPART_FORM_DATA) > > @Produces(MediaType.MULTIPART_FORM_DATA) > > public MultipartBody processMultiparts(MultipartBody multipartBody); > > } > > > > > > @WebService(endpointInterface = "com.abcd.PDFUploadService") > > public class PDFUploadServiceImpl implements PDFUploadService { > > @Override > > public MultipartBody processMultiparts(MultipartBody multipartBody) > { > > if(multipartBody != null) { > > List<Attachment> attachments = > > multipartBody.getAllAttachments(); > > DataHandler dataHandler1 = > > attachments.get(0).getDataHandler(); > > try { > > InputStream inputStream = > > dataHandler1.getInputStream(); > > File outputFile = new File("Output.pdf"); > > OutputStream out=new FileOutputStream(outputFile); > > byte buf[]=new byte[1024]; > > int len; > > while((len=inputStream.read(buf))>0) { > > out.write(buf,0,len); > > } > > out.close(); > > } catch(Exception e) { > > } > > } > > return multipartBody; > > } > > > > } > > > > > > > > Client to invoke this is something like this: > > public class PDFUploadClient { > > > > public static void main(String[] args) throws Exception { > > HttpClient httpclient = new DefaultHttpClient(); > > HttpPost httppost = new HttpPost(" > > http://localhost:8080/myservice/multipart";); > > File inputFile = new File("ChargersLV15.pdf"); > > ContentBody inputFileBody = new FileBody(inputFile); > > MultipartEntity reqEntity = new MultipartEntity(); > > reqEntity.addPart("file", inputFileBody); > > httppost.setEntity(reqEntity); > > httpclient.execute(httppost); > > > > } > > > > > > > > > > > > My requirement is something like: > > @XmlRootElement(name = "CustomRequest") > > public class CustomRequest{ > > > > @XmlElement(name = "id", required = false) > > protected Long id; > > @XmlElement(name = "file", required = false) > > protected File file; > > > > } > > > > > > public interface PDFUploadService { > > @POST > > @Path("/multipart") > > @Consumes(MediaType.MULTIPART_FORM_DATA) > > public Response processMultiparts(CustomRequest customRequest); > > } > > > > > > > > How can I hook individual file to this custom request? Do I have to > mention > > a different mediaType for this? Is there a best way to handle this using > > Base64 encoding? > > > > > > > > > > > > Thanks in advance, > > > > Rama > > > > >
