org.apache.activemq.kaha.impl.data

Class SyncDataFileWriter

java.lang.Object

org.apache.activemq.kaha.impl.data.SyncDataFileWriter

public final class SyncDataFileWriter
extends java.lang.Object

Optimized Store writer. Synchronously marshalls and writes to the data file. Simple but may introduce a bit of contention when put under load.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	force(org.apache.activemq.kaha.impl.data.DataFile dataFile)
DataItem	storeItem(Marshaller marshaller, java.lang.Object payload, byte type)
void	updateItem(DataItem item, Marshaller marshaller, java.lang.Object payload, byte type)

Methods inherited from class java.lang.Object

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

Method Detail

storeItem

public DataItem storeItem(Marshaller marshaller,
                 java.lang.Object payload,
                 byte type)
                   throws java.io.IOException

Throws:

java.io.IOException

updateItem

public void updateItem(DataItem item,
              Marshaller marshaller,
              java.lang.Object payload,
              byte type)
                throws java.io.IOException

Throws:

java.io.IOException

force

public void force(org.apache.activemq.kaha.impl.data.DataFile dataFile)
           throws java.io.IOException

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException