Class JDBCSequentialFile

java.lang.Object

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

All Implemented Interfaces:

org.apache.activemq.artemis.core.io.SequentialFile

public class JDBCSequentialFile
extends Object
implements org.apache.activemq.artemis.core.io.SequentialFile

Method Summary

Modifier and Type	Method	Description
void	addMetaData(Object key, Object value)
void	blockingWriteDirect(ByteBuffer bytes, boolean sync, boolean releaseBuffer)
int	calculateBlockStart(int position)
org.apache.activemq.artemis.core.io.SequentialFile	cloneFile()
void	close()
void	close(boolean waitOnSync, boolean block)
void	copyTo(org.apache.activemq.artemis.core.io.SequentialFile cloneFile)
void	delete()
boolean	exists()
void	fill(int size)
boolean	fits(int size)
String	getExtension()
String	getFilename()
String	getFileName()
long	getId()
File	getJavaFile()
Object	getMetaData(Object key)
int	getNetworkTimeoutMillis()
long	getOid()
boolean	isOpen()
int	jdbcWrite(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer, org.apache.activemq.artemis.core.io.IOCallback callback)
int	jdbcWrite(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer, org.apache.activemq.artemis.core.io.IOCallback callback, boolean append)
ByteBuffer	map(int position, long size)
void	open()
void	open(int maxIO, boolean useExecutor)
long	position()
void	position(long pos)
int	read(ByteBuffer bytes)
int	read(ByteBuffer bytes, org.apache.activemq.artemis.core.io.IOCallback callback)
void	renameTo(String newFileName)
void	sendToDB(org.apache.activemq.artemis.api.core.ActiveMQBuffer bytes, org.apache.activemq.artemis.core.io.IOCallback callback, boolean append)
void	setId(long id)
void	setOid(long oid)
void	setTimedBuffer(org.apache.activemq.artemis.core.io.buffer.TimedBuffer buffer)
long	size()
void	sync()
void	write(org.apache.activemq.artemis.api.core.ActiveMQBuffer bytes, boolean sync)
void	write(org.apache.activemq.artemis.api.core.ActiveMQBuffer bytes, boolean sync, org.apache.activemq.artemis.core.io.IOCallback callback)
void	write(org.apache.activemq.artemis.core.journal.EncodingSupport bytes, boolean sync)
void	write(org.apache.activemq.artemis.core.journal.EncodingSupport bytes, boolean sync, org.apache.activemq.artemis.core.io.IOCallback callback)
void	writeDirect(ByteBuffer bytes, boolean sync)
void	writeDirect(ByteBuffer bytes, boolean sync, org.apache.activemq.artemis.core.io.IOCallback callback)

Methods inherited from class Object

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

Methods inherited from interface org.apache.activemq.artemis.core.io.SequentialFile

afterComplete

Method Details

isOpen

public boolean isOpen()

Specified by:

isOpen in interface org.apache.activemq.artemis.core.io.SequentialFile

exists

public boolean exists()

Specified by:

exists in interface org.apache.activemq.artemis.core.io.SequentialFile

open

public void open()
          throws Exception

Specified by:

open in interface org.apache.activemq.artemis.core.io.SequentialFile

Throws:

Exception

open

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

Specified by:

open in interface org.apache.activemq.artemis.core.io.SequentialFile

Throws:

Exception

fits

public boolean fits(int size)

Specified by:

fits in interface org.apache.activemq.artemis.core.io.SequentialFile

calculateBlockStart

public int calculateBlockStart(int position)
                        throws Exception

Specified by:

calculateBlockStart in interface org.apache.activemq.artemis.core.io.SequentialFile

Throws:

Exception

getFileName

public String getFileName()

Specified by:

getFileName in interface org.apache.activemq.artemis.core.io.SequentialFile

fill

public void fill(int size)
          throws Exception

Specified by:

fill in interface org.apache.activemq.artemis.core.io.SequentialFile

Throws:

Exception

map

public ByteBuffer map(int position,
 long size)
               throws IOException

Specified by:

map in interface org.apache.activemq.artemis.core.io.SequentialFile

Throws:

IOException

delete

public void delete()
            throws IOException,
InterruptedException,
org.apache.activemq.artemis.api.core.ActiveMQException

Specified by:

delete in interface org.apache.activemq.artemis.core.io.SequentialFile

Throws:

IOException

InterruptedException

org.apache.activemq.artemis.api.core.ActiveMQException

jdbcWrite

public int jdbcWrite(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer,
 org.apache.activemq.artemis.core.io.IOCallback callback)

jdbcWrite

public int jdbcWrite(org.apache.activemq.artemis.api.core.ActiveMQBuffer buffer,
 org.apache.activemq.artemis.core.io.IOCallback callback,
 boolean append)

sendToDB

public void sendToDB(org.apache.activemq.artemis.api.core.ActiveMQBuffer bytes,
 org.apache.activemq.artemis.core.io.IOCallback callback,
 boolean append)
              throws Exception

Throws:

Exception

write

public void write(org.apache.activemq.artemis.api.core.ActiveMQBuffer bytes,
 boolean sync,
 org.apache.activemq.artemis.core.io.IOCallback callback)
           throws Exception

Specified by:

write in interface org.apache.activemq.artemis.core.io.SequentialFile

Throws:

Exception

write

public void write(org.apache.activemq.artemis.api.core.ActiveMQBuffer bytes,
 boolean sync)
           throws Exception

Specified by:

write in interface org.apache.activemq.artemis.core.io.SequentialFile

Throws:

Exception

write

public void write(org.apache.activemq.artemis.core.journal.EncodingSupport bytes,
 boolean sync,
 org.apache.activemq.artemis.core.io.IOCallback callback)
           throws Exception

Specified by:

write in interface org.apache.activemq.artemis.core.io.SequentialFile

Throws:

Exception

write

public void write(org.apache.activemq.artemis.core.journal.EncodingSupport bytes,
 boolean sync)
           throws Exception

Specified by:

write in interface org.apache.activemq.artemis.core.io.SequentialFile

Throws:

Exception

writeDirect

public void writeDirect(ByteBuffer bytes,
 boolean sync,
 org.apache.activemq.artemis.core.io.IOCallback callback)

Specified by:

writeDirect in interface org.apache.activemq.artemis.core.io.SequentialFile

blockingWriteDirect

public void blockingWriteDirect(ByteBuffer bytes,
 boolean sync,
 boolean releaseBuffer)

Specified by:

blockingWriteDirect in interface org.apache.activemq.artemis.core.io.SequentialFile

writeDirect

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

Specified by:

writeDirect in interface org.apache.activemq.artemis.core.io.SequentialFile

Throws:

Exception

read

public int read(ByteBuffer bytes,
 org.apache.activemq.artemis.core.io.IOCallback callback)
         throws SQLException

Specified by:

read in interface org.apache.activemq.artemis.core.io.SequentialFile

Throws:

SQLException

read

public int read(ByteBuffer bytes)
         throws Exception

Specified by:

read in interface org.apache.activemq.artemis.core.io.SequentialFile

Throws:

Exception

position

public void position(long pos)
              throws IOException

Specified by:

position in interface org.apache.activemq.artemis.core.io.SequentialFile

Throws:

IOException

position

public long position()

Specified by:

position in interface org.apache.activemq.artemis.core.io.SequentialFile

close

public void close()
           throws Exception

Specified by:

close in interface org.apache.activemq.artemis.core.io.SequentialFile

Throws:

Exception

close

public void close(boolean waitOnSync,
 boolean block)
           throws Exception

Specified by:

close in interface org.apache.activemq.artemis.core.io.SequentialFile

Throws:

Exception

getNetworkTimeoutMillis

public int getNetworkTimeoutMillis()

sync

public void sync()
          throws IOException

Specified by:

sync in interface org.apache.activemq.artemis.core.io.SequentialFile

Throws:

IOException

size

public long size()
          throws Exception

Specified by:

size in interface org.apache.activemq.artemis.core.io.SequentialFile

Throws:

Exception

renameTo

public void renameTo(String newFileName)
              throws Exception

Specified by:

renameTo in interface org.apache.activemq.artemis.core.io.SequentialFile

Throws:

Exception

cloneFile

public org.apache.activemq.artemis.core.io.SequentialFile cloneFile()

Specified by:

cloneFile in interface org.apache.activemq.artemis.core.io.SequentialFile

copyTo

public void copyTo(org.apache.activemq.artemis.core.io.SequentialFile cloneFile)
            throws Exception

Specified by:

copyTo in interface org.apache.activemq.artemis.core.io.SequentialFile

Throws:

Exception

getId

public long getId()

getOid

public long getOid()

setOid

public void setOid(long oid)

setId

public void setId(long id)

getFilename

public String getFilename()

getExtension

public String getExtension()

setTimedBuffer

public void setTimedBuffer(org.apache.activemq.artemis.core.io.buffer.TimedBuffer buffer)

Specified by:

setTimedBuffer in interface org.apache.activemq.artemis.core.io.SequentialFile

getJavaFile

public File getJavaFile()

Specified by:

getJavaFile in interface org.apache.activemq.artemis.core.io.SequentialFile

addMetaData

public void addMetaData(Object key,
 Object value)

getMetaData

public Object getMetaData(Object key)