Не удалось получить весь документ с помощью CXF/MTOM

Question

Я пытаюсь сделать очень простую вещь: клиент вызывает службу SOAP через свой WSDL для загрузки PDF-документа.

Я использую Apache CXF 2.7.5 и MTOM

Проблема заключается в том, что кажется, что документ не будет полностью отправлено на клиента (размер файла не равен оригиналу) и поэтому ADOBE не может открыть его, поскольку он поврежден.

И мой модульный тест, и SOAPUI invokation не удалось.

Если заголовок вопроса должен быть усовершенствован вы радушны

Спасибо заранее.

Сервисный интерфейс

@WebService 
@DataBinding(value = JAXBDataBinding.class) 
public interface DocumentService { 
    @WebMethod(operationName = "getContent") 
    DocumentContentVO getContent(@WebParam(name = "documentId") String documentId); 
} 

Внедрение Service

@WebService(endpointInterface = "com.*.*.ws.sei.DocumentService", portName = "DocumentPort") 
public class CXFDocumentService extends AbstractCommonService implements DocumentService { 
@Override 
public DocumentContentVO getContent(String documentId) { 
    DocumentContentVO contentVO = new DocumentContentVO(); 
    contentVO.setDocumentId(documentId); 
    DataSource ds = new PDFDataSource(nodeService,documentId); 
    contentVO.setContent(new DataHandler(ds)); 
    return contentVO; 
    } 
} 

PDFDataSource

@Component 
public class PDFDataSource implements DataSource { 

public static final String APPLICATION_PDF = "application/pdf"; 
private final String documentId; 
private PCPNodeService nodeService; 

public PDFDataSource(PCPNodeService nodeService, String documentId) { 
    this.documentId = documentId; 
    this.nodeService = nodeService; 
} 

@Override 
public InputStream getInputStream() throws IOException { 
    FileInputStream fis = new FileInputStream("c:/document.pdf"); 
    RemoteInputStream remoteInputStream = nodeService.getNodeInputStream(documentId); 
    return fis; 
} 

@Override 
public OutputStream getOutputStream() throws IOException { 
    return null; 
} 

@Override 
public String getContentType() { 
    return APPLICATION_PDF; 
} 

@Override 
public String getName() { 
    return "INDICATE-DOCUMENT-NAME.pdf"; 
} 
} 

Значение объекта

@XmlRootElement(name = "DocumentContentVO") 
@XmlAccessorType(XmlAccessType.FIELD) 
@BindingType(value = javax.xml.ws.soap.SOAPBinding.SOAP11HTTP_MTOM_BINDING) 
public class DocumentContentVO { 

private String documentId; 

@XmlMimeType("application/octet-stream") 
private DataHandler content; 


public DataHandler getContent() { 
    return content; 
} 

public void setContent(DataHandler content) { 
    this.content = content; 
} 

public String getDocumentId() { 
    return documentId; 
} 

public void setDocumentId(String documentId) { 
    this.documentId = documentId; 
} 

} 

тест Unit (сделать Client Invoke)

public class DocumentWSClientTest { 

@Test 
public void soap_operation_getContent_should_return_pdf_document() throws Exception { 

    final String documentId = "931c43c0-66a1-4ca3-bd86-5195a8f9e3de"; 
    final String wsdl = "http://localhost/pcp-soap/soap/v1/Documents?wsdl"; 
    final String operation = "getContent"; 
    final QName opName = new QName("http://sei.ws.*.*.com/", "getContent"); 

    // 
    JaxWsDynamicClientFactory factory = JaxWsDynamicClientFactory.newInstance(); 
    Client client = factory.createClient(wsdl); 
    Object[] result = client.invoke(opName, documentId); 
    DocumentContentVO documentContentVO = (DocumentContentVO) result[0]; 
    InputStream inputStream = documentContentVO.getContent().getInputStream(); 
    File file = new File("c:/job/test.pdf"); 
    if (file.exists()) { 
     file.delete(); 
    } 
    file.createNewFile(); 
    FileOutputStream outputStream = new FileOutputStream(file); 
    byte[] buffer = new byte[1024]; 
    while (inputStream.read(buffer) > -1) { 
     outputStream.write(buffer); 
    } 
} 
} 

Исключение Stack

org.apache.cxf.interceptor.Fault: Could not write attachments. 
at org.apache.cxf.interceptor.AttachmentOutInterceptor$AttachmentOutEndingInterceptor.handleMessage(AttachmentOutInterceptor.java:105) 
at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:271) 
at org.apache.cxf.interceptor.OutgoingChainInterceptor.handleMessage(OutgoingChainInterceptor.java:77) 
at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:271) 
at org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInitiationObserver.java:121) 
at org.apache.cxf.transport.http.AbstractHTTPDestination.invoke(AbstractHTTPDestination.java:239) 
at org.apache.cxf.transport.servlet.ServletController.invokeDestination(ServletController.java:223) 
at org.apache.cxf.transport.servlet.ServletController.invoke(ServletController.java:203) 
at org.apache.cxf.transport.servlet.ServletController.invoke(ServletController.java:137) 
at org.apache.cxf.transport.servlet.CXFNonSpringServlet.invoke(CXFNonSpringServlet.java:158) 
at org.apache.cxf.transport.servlet.AbstractHTTPServlet.handleRequest(AbstractHTTPServlet.java:243) 
at org.apache.cxf.transport.servlet.AbstractHTTPServlet.doPost(AbstractHTTPServlet.java:163) 
at javax.servlet.http.HttpServlet.service(HttpServlet.java:755) 
at org.apache.cxf.transport.servlet.AbstractHTTPServlet.service(AbstractHTTPServlet.java:219) 
at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:684) 
at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:457) 
at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:137) 
at org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:557) 
at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:231) 
at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1075) 
at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:384) 
at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:193) 
at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1009) 
at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:135) 
at org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:255) 
at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:154) 
at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:116) 
at org.eclipse.jetty.server.Server.handle(Server.java:370) 
at org.eclipse.jetty.server.AbstractHttpConnection.handleRequest(AbstractHttpConnection.java:489) 
at org.eclipse.jetty.server.AbstractHttpConnection.content(AbstractHttpConnection.java:960) 
at org.eclipse.jetty.server.AbstractHttpConnection$RequestHandler.content(AbstractHttpConnection.java:1021) 
at org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:865) 
at org.eclipse.jetty.http.HttpParser.parseAvailable(HttpParser.java:240) 
at org.eclipse.jetty.server.AsyncHttpConnection.handle(AsyncHttpConnection.java:82) 
at org.eclipse.jetty.io.nio.SelectChannelEndPoint.handle(SelectChannelEndPoint.java:668) 
at org.eclipse.jetty.io.nio.SelectChannelEndPoint$1.run(SelectChannelEndPoint.java:52) 
at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:608) 
at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:543) 
at java.lang.Thread.run(Thread.java:662) 
    **Caused by: java.io.IOException: Closed** 
at org.eclipse.jetty.server.HttpOutput.write(HttpOutput.java:140) 
at org.eclipse.jetty.server.HttpOutput.write(HttpOutput.java:107) 
at org.apache.cxf.io.AbstractWrappedOutputStream.write(AbstractWrappedOutputStream.java:51) 
at org.apache.cxf.io.AbstractWrappedOutputStream.write(AbstractWrappedOutputStream.java:60) 
at org.apache.cxf.attachment.AttachmentSerializer.writeAttachments(AttachmentSerializer.java:272) 
at org.apache.cxf.interceptor.AttachmentOutInterceptor$AttachmentOutEndingInterceptor.handleMessage(AttachmentOutInterceptor.java:103) 
... 38 more 

SoapUI httpLog ссылка Pastebin SOAP UI http Log

Answer 1

Решено, потому что что-то не так попало в мою конфигурацию http Apache.