package at.knowcenter.wag.egov.egiz.sig.connectors.moa; import java.io.ByteArrayOutputStream; import java.io.File; import java.io.FileNotFoundException; import java.io.IOException; import java.io.OutputStream; import org.apache.commons.httpclient.methods.multipart.PartSource; import org.apache.commons.httpclient.util.EncodingUtil; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; public class FilePartMR extends org.apache.commons.httpclient.methods.multipart.FilePart { /** Log object for this class. */ private static final Log LOG = LogFactory.getLog(FilePartMR.class); /** Content dispostion characters */ protected static final String CONTENT_ID = "Content-Id: "; /** Content dispostion as a byte array */ protected static final byte[] CONTENT_ID_BYTES = EncodingUtil.getAsciiBytes(CONTENT_ID); private String contentID = ""; public FilePartMR(String arg0, PartSource arg1) { super(arg0, arg1); // TODO Auto-generated constructor stub } public FilePartMR(String arg0, File arg1) throws FileNotFoundException { super(arg0, arg1); // TODO Auto-generated constructor stub } public FilePartMR(String arg0, String arg1, File arg2) throws FileNotFoundException { super(arg0, arg1, arg2); // TODO Auto-generated constructor stub } public FilePartMR(String arg0, PartSource arg1, String arg2, String arg3) { super(arg0, arg1, arg2, arg3); // TODO Auto-generated constructor stub } public FilePartMR(String arg0, File arg1, String arg2, String arg3) throws FileNotFoundException { super(arg0, arg1, arg2, arg3); // TODO Auto-generated constructor stub } public FilePartMR(String arg0, String arg1, File arg2, String arg3, String arg4) throws FileNotFoundException { super(arg0, arg1, arg2, arg3, arg4); // TODO Auto-generated constructor stub } public void setContentID(String contentid) { this.contentID = contentid; } public String getContentID() { return this.contentID; } /** * Write the content id header to the specified output stream * * @param out The output stream * @throws IOException If an IO problem occurs. */ protected void sendContentIDHeader(OutputStream out) throws IOException { LOG.trace("enter sendContendID instead of ContentDisposition(OutputStream out)"); out.write(CONTENT_ID_BYTES); out.write(EncodingUtil.getAsciiBytes(getContentID())); } /** * Write all the data to the output stream. * If you override this method make sure to override * #length() as well * * @param out The output stream * @throws IOException If an IO problem occurs. */ public void send(OutputStream out) throws IOException { LOG.trace("enter send(OutputStream out)"); sendStart(out); sendContentIDHeader(out); sendContentTypeHeader(out); sendTransferEncodingHeader(out); sendEndOfHeader(out); sendData(out); sendEnd(out); } /** * Return the full length of all the data. * If you override this method make sure to override * #send(OutputStream) as well * * @return long The length. * @throws IOException If an IO problem occurs */ public long length() throws IOException { LOG.trace("enter length()"); if (lengthOfData() < 0) { return -1; } ByteArrayOutputStream overhead = new ByteArrayOutputStream(); sendStart(overhead); sendContentIDHeader(overhead); sendContentTypeHeader(overhead); sendTransferEncodingHeader(overhead); sendEndOfHeader(overhead); sendEnd(overhead); return overhead.size() + lengthOfData(); } }