Class JDBCSequentialFileFactory

java.lang.Object

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

All Implemented Interfaces:

org.apache.activemq.artemis.core.io.SequentialFileFactory, org.apache.activemq.artemis.core.server.ActiveMQComponent

public class JDBCSequentialFileFactory
extends Object
implements org.apache.activemq.artemis.core.io.SequentialFileFactory, org.apache.activemq.artemis.core.server.ActiveMQComponent

Constructor Summary

Constructors

Constructor	Description
JDBCSequentialFileFactory(JDBCConnectionProvider connectionProvider, SQLProvider sqlProvider, Executor executor, ScheduledExecutorService scheduledExecutorService, long syncDelay, org.apache.activemq.artemis.core.io.IOCriticalErrorListener criticalErrorListener)

Method Summary

Modifier and Type	Method	Description
void	activateBuffer(org.apache.activemq.artemis.core.io.SequentialFile file)
ByteBuffer	allocateDirectBuffer(int size)
int	calculateBlockSize(int bytes)
void	clearBuffer(ByteBuffer buffer)
void	createDirs()
org.apache.activemq.artemis.core.io.SequentialFile	createSequentialFile(String fileName)
void	deactivateBuffer()
void	destroy()
void	flush()
int	getAlignment()
long	getBufferSize()
JDBCSequentialFileFactoryDriver	getDbDriver()
File	getDirectory()
String	getDirectoryName()
int	getMaxIO()
int	getNumberOfOpenFiles()
boolean	isDatasync()
boolean	isStarted()
boolean	isSupportsCallbacks()
List<String>	listFiles(String extension)
ByteBuffer	newBuffer(int size)
void	onIOError(Throwable exception, String message, String file)
void	releaseBuffer(ByteBuffer buffer)
void	releaseDirectBuffer(ByteBuffer buffer)
void	sequentialFileClosed(org.apache.activemq.artemis.core.io.SequentialFile file)
JDBCSequentialFileFactory	setAlignment(int alignment)
org.apache.activemq.artemis.core.io.SequentialFileFactory	setDatasync(boolean enabled)
void	start()
void	stop()
boolean	supportsIndividualContext()
ByteBuffer	wrapBuffer(byte[] bytes)

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.server.ActiveMQComponent

asyncStop

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

createSequentialFile, deleteFolder, getCriticalAnalyzer, getCriticalErrorListener, isSyncSupported, newBuffer, onIOError, onIOError, setCriticalErrorListener

Constructor Details

JDBCSequentialFileFactory

public JDBCSequentialFileFactory(JDBCConnectionProvider connectionProvider,
 SQLProvider sqlProvider,
 Executor executor,
 ScheduledExecutorService scheduledExecutorService,
 long syncDelay,
 org.apache.activemq.artemis.core.io.IOCriticalErrorListener criticalErrorListener)
                          throws Exception

Throws:

Exception

Method Details

supportsIndividualContext

public boolean supportsIndividualContext()

Specified by:

supportsIndividualContext in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

getDbDriver

public JDBCSequentialFileFactoryDriver getDbDriver()

setDatasync

public org.apache.activemq.artemis.core.io.SequentialFileFactory setDatasync(boolean enabled)

Specified by:

setDatasync in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

isDatasync

public boolean isDatasync()

Specified by:

isDatasync in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

getBufferSize

public long getBufferSize()

Specified by:

getBufferSize in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

start

public void start()

Specified by:

start in interface org.apache.activemq.artemis.core.server.ActiveMQComponent

Specified by:

start in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

stop

public void stop()

Specified by:

stop in interface org.apache.activemq.artemis.core.server.ActiveMQComponent

Specified by:

stop in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

createSequentialFile

public org.apache.activemq.artemis.core.io.SequentialFile createSequentialFile(String fileName)

Specified by:

createSequentialFile in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

sequentialFileClosed

public void sequentialFileClosed(org.apache.activemq.artemis.core.io.SequentialFile file)

getNumberOfOpenFiles

public int getNumberOfOpenFiles()

getMaxIO

public int getMaxIO()

Specified by:

getMaxIO in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

listFiles

public List<String> listFiles(String extension)
                       throws Exception

Specified by:

listFiles in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

Throws:

Exception

isSupportsCallbacks

public boolean isSupportsCallbacks()

Specified by:

isSupportsCallbacks in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

onIOError

public void onIOError(Throwable exception,
 String message,
 String file)

Specified by:

onIOError in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

allocateDirectBuffer

public ByteBuffer allocateDirectBuffer(int size)

Specified by:

allocateDirectBuffer in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

releaseDirectBuffer

public void releaseDirectBuffer(ByteBuffer buffer)

Specified by:

releaseDirectBuffer in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

newBuffer

public ByteBuffer newBuffer(int size)

Specified by:

newBuffer in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

clearBuffer

public void clearBuffer(ByteBuffer buffer)

Specified by:

clearBuffer in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

wrapBuffer

public ByteBuffer wrapBuffer(byte[] bytes)

Specified by:

wrapBuffer in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

getAlignment

public int getAlignment()

Specified by:

getAlignment in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

setAlignment

public JDBCSequentialFileFactory setAlignment(int alignment)

Specified by:

setAlignment in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

calculateBlockSize

public int calculateBlockSize(int bytes)

Specified by:

calculateBlockSize in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

deactivateBuffer

public void deactivateBuffer()

Specified by:

deactivateBuffer in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

releaseBuffer

public void releaseBuffer(ByteBuffer buffer)

Specified by:

releaseBuffer in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

activateBuffer

public void activateBuffer(org.apache.activemq.artemis.core.io.SequentialFile file)

Specified by:

activateBuffer in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

getDirectory

public File getDirectory()

Specified by:

getDirectory in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

getDirectoryName

public String getDirectoryName()

Specified by:

getDirectoryName in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

isStarted

public boolean isStarted()

Specified by:

isStarted in interface org.apache.activemq.artemis.core.server.ActiveMQComponent

createDirs

public void createDirs()
                throws Exception

Specified by:

createDirs in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

Throws:

Exception

flush

public void flush()

Specified by:

flush in interface org.apache.activemq.artemis.core.io.SequentialFileFactory

destroy

public void destroy()
             throws SQLException

Throws:

SQLException