Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » kaha » impl » async » [javadoc | source]
class: NIODataFileAppender [javadoc | source]
An AsyncDataFileAppender that uses NIO ByteBuffers and File chanels to more efficently copy data to files.
Fields inherited from org.apache.activemq.kaha.impl.async.DataFileAppender:
RESERVED_SPACE,  DEFAULT_MAX_BATCH_SIZE,  dataManager,  inflightWrites,  enqueueMutex,  nextWriteBatch,  shutdown,  firstAsyncException,  shutdownDone,  maxWriteBatchSize,  running
 public NIODataFileAppender(AsyncDataManager fileManager) 
Method from org.apache.activemq.kaha.impl.async.NIODataFileAppender Summary:
Methods from org.apache.activemq.kaha.impl.async.DataFileAppender:
close,   processQueue,   storeItem,   storeItem
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.kaha.impl.async.NIODataFileAppender Detail:
 protected  void processQueue() 
    The async processing loop that writes to the data files and does the force calls. Since the file sync() call is the slowest of all the operations, this algorithm tries to 'batch' or group together several file sync() requests into a single file sync() call. The batching is accomplished attaching the same CountDownLatch instance to every force request in a group.