org.apache.axis.attachments
Class ManagedMemoryDataSource

java.lang.Object
  |
  +--org.apache.axis.attachments.ManagedMemoryDataSource

All Implemented Interfaces:

javax.activation.DataSource

public class ManagedMemoryDataSource

extends java.lang.Object

implements javax.activation.DataSource

This class allows small attachments to be cached in memory, while large ones are cached out. It implements a Java Activiation Data source interface. TODO TODO TODO need to delete cached out data sources after a service ends.

Author:

Rick Rineholt

Field Summary

protected java.io.BufferedOutputStream	cachediskstream Field cachediskstream
protected boolean	closed Field closed
protected java.lang.String	contentType Field contentType
protected byte[]	currentMemoryBuf Field currentMemoryBuf
protected int	currentMemoryBufSz Field currentMemoryBufSz
protected boolean	debugEnabled Field debugEnabled
protected boolean	deleted Field deleted
protected java.io.File	diskCacheFile Field diskCacheFile
protected static org.apache.commons.logging.Log	is_log Field is_log
protected static org.apache.commons.logging.Log	log Field log
static int	MAX_MEMORY_DISK_CACHED Field MAX_MEMORY_DISK_CACHED
protected int	maxCached Field maxCached
protected java.util.LinkedList	memorybuflist Field memorybuflist
static int	MIN_MEMORY_DISK_CACHED Field MIN_MEMORY_DISK_CACHED
static int	READ_CHUNK_SZ Field READ_CHUNK_SZ
protected java.util.WeakHashMap	readers Field readers
protected int	totalsz Field totalsz

Constructor Summary

protected	ManagedMemoryDataSource() Constructor ManagedMemoryDataSource
	ManagedMemoryDataSource(java.io.InputStream ss, int maxCached, java.lang.String contentType) Create a new boundary stream;
	ManagedMemoryDataSource(java.io.InputStream ss, int maxCached, java.lang.String contentType, boolean readall) Create a new boundary stream;

Method Summary

protected void	close() This method is a low level write.
boolean	delete() Method delete
protected void	finalize() Method finalize
protected void	flushToDisk() Routine to flush data to disk if is in memory.
java.lang.String	getContentType() This method returns the MIME type of the data in the form of a string.
java.io.File	getDiskCacheFile() get the filename of the content if it is cached to disk.
java.io.InputStream	getInputStream() This method returns an InputStream representing the the data and throws the appropriate exception if it can not do so.
java.lang.String	getName() This will flush any memory source to disk and provide the name of the file if desired.
java.io.OutputStream	getOutputStream() This method returns an OutputStream where the data can be written and throws the appropriate exception if it can not do so.
static void	main(java.lang.String[] arg) Method main
protected void	write(byte[] data) Write bytes to the stream.
protected void	write(byte[] data, int length) This method is a low level write.

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static org.apache.commons.logging.Log log

Field log

contentType

protected java.lang.String contentType

Field contentType

MIN_MEMORY_DISK_CACHED

public static final int MIN_MEMORY_DISK_CACHED

Field MIN_MEMORY_DISK_CACHED

See Also:

Constant Field Values

MAX_MEMORY_DISK_CACHED

public static final int MAX_MEMORY_DISK_CACHED

Field MAX_MEMORY_DISK_CACHED

See Also:

Constant Field Values

maxCached

protected int maxCached

Field maxCached

diskCacheFile

protected java.io.File diskCacheFile

Field diskCacheFile

readers

protected java.util.WeakHashMap readers

Field readers

deleted

protected boolean deleted

Field deleted

READ_CHUNK_SZ

public static final int READ_CHUNK_SZ

Field READ_CHUNK_SZ

See Also:

Constant Field Values

debugEnabled

protected boolean debugEnabled

Field debugEnabled

memorybuflist

protected java.util.LinkedList memorybuflist

Field memorybuflist

currentMemoryBuf

protected byte[] currentMemoryBuf

Field currentMemoryBuf

currentMemoryBufSz

protected int currentMemoryBufSz

Field currentMemoryBufSz

totalsz

protected int totalsz

Field totalsz

cachediskstream

protected java.io.BufferedOutputStream cachediskstream

Field cachediskstream

closed

protected boolean closed

Field closed

is_log

protected static org.apache.commons.logging.Log is_log

Field is_log

Constructor Detail

ManagedMemoryDataSource

protected ManagedMemoryDataSource()

Constructor ManagedMemoryDataSource

ManagedMemoryDataSource

public ManagedMemoryDataSource(java.io.InputStream ss,
                               int maxCached,
                               java.lang.String contentType)
                        throws java.io.IOException

Create a new boundary stream;

Parameters:

ss - is the source input stream that is used to create this data source..

maxCached - This is the max memory that is to be used to cache the data.

contentType - the mime type for this data stream. by buffering you can some effiency in searching.

Throws:

java.io.IOException

ManagedMemoryDataSource

public ManagedMemoryDataSource(java.io.InputStream ss,
                               int maxCached,
                               java.lang.String contentType,
                               boolean readall)
                        throws java.io.IOException

Create a new boundary stream;

Parameters:

ss - is the source input stream that is used to create this data source..

maxCached - This is the max memory that is to be used to cache the data.

contentType - the mime type for this data stream. by buffering you can some effiency in searching.

readall - if true will read in the whole source.

Throws:

java.io.IOException

Method Detail

getContentType

public java.lang.String getContentType()

This method returns the MIME type of the data in the form of a string.

Specified by:

getContentType in interface javax.activation.DataSource

Returns:

The mime type.

getInputStream

public java.io.InputStream getInputStream()
                                   throws java.io.IOException

This method returns an InputStream representing the the data and throws the appropriate exception if it can not do so.

Specified by:

getInputStream in interface javax.activation.DataSource

Returns:

the java.io.InputStream for the data source.

Throws:

java.io.IOException

getName

public java.lang.String getName()

This will flush any memory source to disk and provide the name of the file if desired. Return the name of the file of the stream.

Specified by:

getName in interface javax.activation.DataSource

Returns:

getOutputStream

public java.io.OutputStream getOutputStream()
                                     throws java.io.IOException

This method returns an OutputStream where the data can be written and throws the appropriate exception if it can not do so. NOT SUPPORTED, not need for axis, data sources are create by constructors.

Specified by:

getOutputStream in interface javax.activation.DataSource

Returns:

Throws:

java.io.IOException

write

protected void write(byte[] data)
              throws java.io.IOException

Write bytes to the stream.

Parameters:

data - all bytes of this array are written to the stream.

Throws:

java.io.IOException

write

protected void write(byte[] data,
                     int length)
              throws java.io.IOException

This method is a low level write. Note it is designed to in the future to allow streaming to both memory AND to disk simultaneously.

Parameters:

data -

length -

Throws:

java.io.IOException

close

protected void close()
              throws java.io.IOException

This method is a low level write. Close the stream.

Throws:

java.io.IOException

finalize

protected void finalize()
                 throws java.lang.Throwable

Method finalize

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable

flushToDisk

protected void flushToDisk()
                    throws java.io.IOException,
                           java.io.FileNotFoundException

Routine to flush data to disk if is in memory.

Throws:

java.io.IOException

java.io.FileNotFoundException

delete

public boolean delete()

Method delete

Returns:

main

public static void main(java.lang.String[] arg)

Method main

Parameters:

arg -

getDiskCacheFile

public java.io.File getDiskCacheFile()

get the filename of the content if it is cached to disk.

Returns:

file object pointing to file, or null for memory-stored content