org.broadleafcommerce.common.io

Class ConcurrentFileOutputStreamImpl

java.lang.Object

org.broadleafcommerce.common.io.ConcurrentFileOutputStreamImpl

All Implemented Interfaces:

ConcurrentFileOutputStream

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

Field Summary

Fields

Modifier and Type	Field and Description
protected int	defaultFileBufferSize

Constructor Summary

Constructors

Constructor and Description
ConcurrentFileOutputStreamImpl()

Method Summary

Modifier and Type	Method and 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 Detail

defaultFileBufferSize

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

Constructor Detail

ConcurrentFileOutputStreamImpl

public ConcurrentFileOutputStreamImpl()

Method Detail

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)