org.apache.activemq.artemis.jdbc.store.file

Class JDBCSequentialFile

java.lang.Object

org.apache.activemq.artemis.jdbc.store.file.JDBCSequentialFile

All Implemented Interfaces:

SequentialFile

public class JDBCSequentialFile
extends Object
implements SequentialFile

Constructor Summary

Constructors

Constructor and Description
JDBCSequentialFile(JDBCSequentialFileFactory fileFactory, String filename, Executor executor, JDBCSequentialFileFactoryDriver driver, Object writeLock)

Method Summary

Modifier and Type	Method and Description
void	addMetaData(Object key, Object value)
int	calculateBlockStart(int position)
SequentialFile	cloneFile()
void	close()
void	copyTo(SequentialFile cloneFile)
void	delete()
boolean	exists()
void	fill(int size)
boolean	fits(int size)
int	getAlignment()
String	getExtension()
String	getFilename()
String	getFileName()
int	getId()
File	getJavaFile() Returns a native File of the file underlying this sequential file.
Object	getMetaData(Object key)
int	internalWrite(ActiveMQBuffer buffer, IOCallback callback)
boolean	isOpen()
void	open()
void	open(int maxIO, boolean useExecutor) The maximum number of simultaneous writes accepted
long	position()
void	position(long pos)
int	read(ByteBuffer bytes)
int	read(ByteBuffer bytes, IOCallback callback)
Object	removeMetaData(Object key)
void	renameTo(String newFileName)
void	scheduleWrite(ActiveMQBuffer bytes, IOCallback callback)
void	scheduleWrite(ByteBuffer bytes, IOCallback callback)
void	setId(int id)
void	setTimedBuffer(TimedBuffer buffer)
void	setWritePosition(int writePosition)
long	size()
void	sync()
void	write(ActiveMQBuffer bytes, boolean sync)
void	write(ActiveMQBuffer bytes, boolean sync, IOCallback callback)
void	write(EncodingSupport bytes, boolean sync)
void	write(EncodingSupport bytes, boolean sync, IOCallback callback)
void	writeDirect(ByteBuffer bytes, boolean sync) Write directly to the file without using intermediate any buffer
void	writeDirect(ByteBuffer bytes, boolean sync, IOCallback callback) Write directly to the file without using any buffer

Methods inherited from class java.lang.Object

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

Constructor Detail

JDBCSequentialFile

public JDBCSequentialFile(JDBCSequentialFileFactory fileFactory,
                          String filename,
                          Executor executor,
                          JDBCSequentialFileFactoryDriver driver,
                          Object writeLock)
                   throws SQLException

Throws:

SQLException

Method Detail

setWritePosition

public void setWritePosition(int writePosition)

isOpen

public boolean isOpen()

Specified by:

isOpen in interface SequentialFile

exists

public boolean exists()

Specified by:

exists in interface SequentialFile

open

public void open()
          throws Exception

Specified by:

open in interface SequentialFile

Throws:

Exception

open

public void open(int maxIO,
                 boolean useExecutor)
          throws Exception

Description copied from interface: SequentialFile

The maximum number of simultaneous writes accepted

Specified by:

open in interface SequentialFile

Throws:

Exception

fits

public boolean fits(int size)

Specified by:

fits in interface SequentialFile

getAlignment

public int getAlignment()
                 throws Exception

Specified by:

getAlignment in interface SequentialFile

Throws:

Exception

calculateBlockStart

public int calculateBlockStart(int position)
                        throws Exception

Specified by:

calculateBlockStart in interface SequentialFile

Throws:

Exception

getFileName

public String getFileName()

Specified by:

getFileName in interface SequentialFile

fill

public void fill(int size)
          throws Exception

Specified by:

fill in interface SequentialFile

Throws:

Exception

delete

public void delete()
            throws IOException,
                   InterruptedException,
                   ActiveMQException

Specified by:

delete in interface SequentialFile

Throws:

IOException

InterruptedException

ActiveMQException

internalWrite

public int internalWrite(ActiveMQBuffer buffer,
                         IOCallback callback)

scheduleWrite

public void scheduleWrite(ActiveMQBuffer bytes,
                          IOCallback callback)

scheduleWrite

public void scheduleWrite(ByteBuffer bytes,
                          IOCallback callback)

write

public void write(ActiveMQBuffer bytes,
                  boolean sync,
                  IOCallback callback)
           throws Exception

Specified by:

write in interface SequentialFile

Throws:

Exception

write

public void write(ActiveMQBuffer bytes,
                  boolean sync)
           throws Exception

Specified by:

write in interface SequentialFile

Throws:

Exception

write

public void write(EncodingSupport bytes,
                  boolean sync,
                  IOCallback callback)
           throws Exception

Specified by:

write in interface SequentialFile

Throws:

Exception

write

public void write(EncodingSupport bytes,
                  boolean sync)
           throws Exception

Specified by:

write in interface SequentialFile

Throws:

Exception

writeDirect

public void writeDirect(ByteBuffer bytes,
                        boolean sync,
                        IOCallback callback)

Description copied from interface: SequentialFile

Write directly to the file without using any buffer

Specified by:

writeDirect in interface SequentialFile

Parameters:

bytes - the ByteBuffer must be compatible with the SequentialFile implementation (AIO or NIO). To be safe, use a buffer from the corresponding SequentialFileFactory.newBuffer(int).

writeDirect

public void writeDirect(ByteBuffer bytes,
                        boolean sync)
                 throws Exception

Description copied from interface: SequentialFile

Write directly to the file without using intermediate any buffer

Specified by:

writeDirect in interface SequentialFile

Parameters:

bytes - the ByteBuffer must be compatible with the SequentialFile implementation (AIO or NIO). To be safe, use a buffer from the corresponding SequentialFileFactory.newBuffer(int).

Throws:

Exception

read

public int read(ByteBuffer bytes,
                IOCallback callback)
         throws SQLException

Specified by:

read in interface SequentialFile

Parameters:

bytes - the ByteBuffer must be compatible with the SequentialFile implementation (AIO or NIO). To be safe, use a buffer from the corresponding SequentialFileFactory.newBuffer(int).

Throws:

SQLException

read

public int read(ByteBuffer bytes)
         throws Exception

Specified by:

read in interface SequentialFile

Parameters:

bytes - the ByteBuffer must be compatible with the SequentialFile implementation (AIO or NIO). To be safe, use a buffer from the corresponding SequentialFileFactory.newBuffer(int).

Throws:

Exception

position

public void position(long pos)
              throws IOException

Specified by:

position in interface SequentialFile

Throws:

IOException

position

public long position()

Specified by:

position in interface SequentialFile

close

public void close()
           throws Exception

Specified by:

close in interface SequentialFile

Throws:

Exception

sync

public void sync()
          throws IOException

Specified by:

sync in interface SequentialFile

Throws:

IOException

size

public long size()
          throws Exception

Specified by:

size in interface SequentialFile

Throws:

Exception

renameTo

public void renameTo(String newFileName)
              throws Exception

Specified by:

renameTo in interface SequentialFile

Throws:

Exception

cloneFile

public SequentialFile cloneFile()

Specified by:

cloneFile in interface SequentialFile

copyTo

public void copyTo(SequentialFile cloneFile)
            throws Exception

Specified by:

copyTo in interface SequentialFile

Throws:

Exception

getId

public int getId()

setId

public void setId(int id)

getFilename

public String getFilename()

getExtension

public String getExtension()

setTimedBuffer

public void setTimedBuffer(TimedBuffer buffer)

Specified by:

setTimedBuffer in interface SequentialFile

getJavaFile

public File getJavaFile()

Description copied from interface: SequentialFile

Returns a native File of the file underlying this sequential file.

Specified by:

getJavaFile in interface SequentialFile

addMetaData

public void addMetaData(Object key,
                        Object value)

removeMetaData

public Object removeMetaData(Object key)

getMetaData

public Object getMetaData(Object key)