Save This Page
Home » activemq-parent-5.3.1-source-release » org.apache » activemq » kaha » impl » async » [javadoc | source]
org.apache.activemq.kaha.impl.async
class: NIODataFileAppender [javadoc | source]
java.lang.Object
   org.apache.activemq.kaha.impl.async.DataFileAppender
      org.apache.activemq.kaha.impl.async.NIODataFileAppender
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
Constructor:
 public NIODataFileAppender(AsyncDataManager fileManager) 
Method from org.apache.activemq.kaha.impl.async.NIODataFileAppender Summary:
processQueue
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.