Package org.broadleafcommerce.common.io

Class ConcurrentFileOutputStreamImpl

java.lang.Object

org.broadleafcommerce.common.io.ConcurrentFileOutputStreamImpl

All Implemented Interfaces:

ConcurrentFileOutputStream

@Component("blConcurrentFileOutputStream")
public class ConcurrentFileOutputStreamImpl
extends Object
implements ConcurrentFileOutputStream

Field Summary

Fields

Modifier and Type	Field	Description
protected int	defaultFileBufferSize

Constructor Summary

Constructors

Constructor	Description
ConcurrentFileOutputStreamImpl()

Method Summary

Modifier and Type	Method	Description
protected File	createTempFile(File dest)
protected Object	getFileMoveLock(File file)
protected String	getTempFileSuffix()
protected void	replaceExisting(File src, File dest)
int	write(InputStream src, File dest)
int	write(InputStream src, File dest, int bufferSize)
protected int	writeToTempFile(InputStream src, File tempFile, int bufferSize)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

defaultFileBufferSize

@Value("${asset.server.file.buffer.size:8192}")
protected int defaultFileBufferSize

Constructor Details

ConcurrentFileOutputStreamImpl

public ConcurrentFileOutputStreamImpl()

Method Details

write

public int write(InputStream src,
 File dest)
          throws IOException

Specified by:

write in interface ConcurrentFileOutputStream

Throws:

IOException

write

public int write(InputStream src,
 File dest,
 int bufferSize)
          throws IOException

Specified by:

write in interface ConcurrentFileOutputStream

Throws:

IOException

createTempFile

protected File createTempFile(File dest)
                       throws IOException

Throws:

IOException

getTempFileSuffix

protected String getTempFileSuffix()

writeToTempFile

protected int writeToTempFile(InputStream src,
 File tempFile,
 int bufferSize)
                       throws IOException

Throws:

IOException

replaceExisting

protected void replaceExisting(File src,
 File dest)
                        throws IOException

Throws:

IOException

getFileMoveLock

protected Object getFileMoveLock(File file)