Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep

Package org.activemq.io.util

Interface Summary
MemoryBoundedObject  
MemoryManageable  
 

Class Summary
ByteArray Simple holder for a an array of Bytes - used instead of a ByteBuffer to avoid unecessary System.array() copies
ByteArrayCompression Compression stream
ByteArrayCompressionTest ByteArrayCompressionTest
ByteArrayFragmentation Compression stream
ByteArrayFragmentationTest ByteArrayFragmentationTest
DataContainer A DataContainer handles file persistence for a DiskBoundedQueue The DataContainer is a temporary data structure, that is only designed to exist for the lifetime of the application
FileDataBlock Simply writes/reads data from a RandomAccessFile
MemoryBoundedMessageCache A simple cache that stores messages in memory.
MemoryBoundedMessageCache.CacheNode Used associate the a Message to it's QueueListEntry in the lruList
MemoryBoundedMessageCacheTest MemoryBoundedQueueTest
MemoryBoundedObjectManager Keeps track of MemoryBoundedObjects
MemoryBoundedPrioritizedQueue  
MemoryBoundedPrioritizedQueueTest  
MemoryBoundedQueue MemoryBoundedQueue is a queue bounded by memory usage for MemoryManageables
MemoryBoundedQueueManager A factory manager for MemoryBoundedQueue and also ensures that the maximum memory used by all active MemoryBoundedQueues created by this instance stays within the memory usage bounds set.
MemoryBoundedQueueTest MemoryBoundedQueueTest
SpooledBoundedActiveMQMessageQueue Implements a controlled thread safe queue, with ActiveMQMessages being spooled to disk for reading asynchronously.
WireByteArrayInputStream Optimized ByteArrayInputStream that can be used more than once.
WireByteArrayOutputStream Optimized ByteArrayOutputStream
WireGZIPOutputStream Compression stream