Can MTOM attachments sent to a CXF web service be processed in parallel ?

marcelcasado Aug 8, 2009 5:50 AM

Hi,

I have a CXF web service deployed on Fuse ESB, the soap request contains an array of the same xml element that contains an attachment on each one. I want to process them (save them to disk an then process them) in parallel using a different thread for each element containing an attachment using the "java.util.concurrent" multithreading features. For each element in the list I got a DataHandler and then I get the InputStream to save the attachment to a file using a BufferOutStream. My code is thread safe. When I test the service Im getting weird exceptions when the attachments are going to be saved to a file that I'm not able to figure out what is wrong. The service works fine if I process the attachments sequentially but takes for ever.

Is there something in the way that MTOM attachments are processed on CXF that does not allow to process them in parallel ?

Thanks in advance,

-Marcel

1. Re: Can MTOM attachments sent to a CXF web service be processed in parallel ?

martinmurphy Aug 10, 2009 7:36 AM (in response to marcelcasado)

Apologies, but I'm not certain I follow your threading model here. I am assuming you have implemented the threading model you describe below in your implementation of the operation and are not relying on CXF for this?

The one thing to watch out for when you are using MTOM attachments is to be sure that you close any input streams that you get. CXF will keep a count of all input streams it hands out, and will decrease this when stream is closed. When the count is zero it then knows the file can be deleted. I'm not sure if this could be causing any problems you are seeing, but it's a common mistake.
Actions
2. Re: Can MTOM attachments sent to a CXF web service be processed in parallel

marcelcasado Jan 29, 2010 9:30 AM (in response to marcelcasado)

It looks like it was a bug indeed see :

http://issues.apache.org/jira/browse/CXF-2381
Actions

Go to original post