Overview  Package  Class  Use  Deprecated   Index
Home >> All >> org >> activemq >> io >> [ util overview ]	PREV  NEXT

A B C D E F G I L M N O P Q R S T U W

---

A

activate() - Method in class org.activemq.io.util.FileDataBlock

 

activeQueues - Variable in class org.activemq.io.util.MemoryBoundedQueueManager

 

add(MemoryBoundedObject) - Method in class org.activemq.io.util.MemoryBoundedObjectManager

 

add(MemoryBoundedQueue) - Method in class org.activemq.io.util.MemoryBoundedQueueManager

 

assemble(ByteArray[]) - Method in class org.activemq.io.util.ByteArrayFragmentation

Assemble a ByteArray from an array of fragements

available() - Method in class org.activemq.io.util.WireByteArrayInputStream

 

---

B

ByteArray - class org.activemq.io.util.ByteArray.

Simple holder for a an array of Bytes - used instead of a ByteBuffer to avoid unecessary System.array() copies

ByteArray() - Constructor for class org.activemq.io.util.ByteArray

Construct an empty ByteArray

ByteArray(byte[]) - Constructor for class org.activemq.io.util.ByteArray

Create a byte array

ByteArray(byte[], int, int) - Constructor for class org.activemq.io.util.ByteArray

Create a ByteArray

ByteArrayCompression - class org.activemq.io.util.ByteArrayCompression.

Compression stream

ByteArrayCompression() - Constructor for class org.activemq.io.util.ByteArrayCompression

 

ByteArrayCompressionTest - class org.activemq.io.util.ByteArrayCompressionTest.

ByteArrayCompressionTest

ByteArrayCompressionTest() - Constructor for class org.activemq.io.util.ByteArrayCompressionTest

 

ByteArrayFragmentation - class org.activemq.io.util.ByteArrayFragmentation.

Compression stream

ByteArrayFragmentation() - Constructor for class org.activemq.io.util.ByteArrayFragmentation

 

ByteArrayFragmentationTest - class org.activemq.io.util.ByteArrayFragmentationTest.

ByteArrayFragmentationTest

ByteArrayFragmentationTest(String) - Constructor for class org.activemq.io.util.ByteArrayFragmentationTest

Constructor for ByteArrayFragmentationTest.

buf - Variable in class org.activemq.io.util.ByteArray

 

---

C

clear() - Method in class org.activemq.io.util.ByteArray

clear the values held by this ByteArray

clear() - Method in class org.activemq.io.util.MemoryBoundedPrioritizedQueue

remove any MemoryManageables in the queue

clear() - Method in class org.activemq.io.util.MemoryBoundedQueue

remove any MemoryManageables in the queue

clear() - Method in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

clear the queue

close() - Method in class org.activemq.io.util.DataContainer

close the DataContainer and corresponding FileDataBlocks

close() - Method in class org.activemq.io.util.FileDataBlock

close and deletes the block

close() - Method in class org.activemq.io.util.MemoryBoundedMessageCache

 

close() - Method in interface org.activemq.io.util.MemoryBoundedObject

 

close() - Method in class org.activemq.io.util.MemoryBoundedObjectManager

close this queue manager and all associated MemoryBoundedQueues

close() - Method in class org.activemq.io.util.MemoryBoundedQueue

close and remove this queue from the MemoryBoundedQueueManager

close() - Method in class org.activemq.io.util.MemoryBoundedQueueManager

close this queue manager and all associated MemoryBoundedQueues

close() - Method in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

close this queue

closed - Variable in class org.activemq.io.util.MemoryBoundedMessageCache

 

closed - Variable in class org.activemq.io.util.MemoryBoundedObjectManager

 

closed - Variable in class org.activemq.io.util.MemoryBoundedQueue

 

closed - Variable in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

 

compressionLevel - Variable in class org.activemq.io.util.ByteArrayCompression

 

compressionLimit - Variable in class org.activemq.io.util.ByteArrayCompression

 

compressionStrategy - Variable in class org.activemq.io.util.ByteArrayCompression

 

container - Variable in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

 

copy() - Method in class org.activemq.io.util.ByteArray

make a copy

createDataBlock(int) - Method in class org.activemq.io.util.DataContainer

create a FileDataBlock

currentOffset - Variable in class org.activemq.io.util.FileDataBlock

 

---

D

DATA_SIZE - Static variable in class org.activemq.io.util.ByteArrayCompressionTest

 

DATA_SIZE - Static variable in class org.activemq.io.util.ByteArrayFragmentationTest

 

DEFAULT_COMPRESSION_LEVEL - Static variable in class org.activemq.io.util.ByteArrayCompression

Default compression level - 0 being none, 9 being best

DEFAULT_COMPRESSION_LIMIT - Static variable in class org.activemq.io.util.ByteArrayCompression

Data size above which compression will be used

DEFAULT_COMPRESSION_STRATEGY - Static variable in class org.activemq.io.util.ByteArrayCompression

Default Compression Strategy

DEFAULT_FRAGMENTATION_LIMIT - Static variable in class org.activemq.io.util.ByteArrayFragmentation

Data size above which fragmentation will be used

DEFAULT_PRIORITY - Static variable in class org.activemq.io.util.MemoryBoundedPrioritizedQueue

 

DataContainer - class org.activemq.io.util.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

DataContainer(File, String, int) - Constructor for class org.activemq.io.util.DataContainer

Constructor for the data container

dataBlock - Variable in class org.activemq.io.util.FileDataBlock

 

dataBlocks - Variable in class org.activemq.io.util.DataContainer

 

deactivate() - Method in class org.activemq.io.util.FileDataBlock

 

decrementMemoryReferenceCount() - Method in interface org.activemq.io.util.MemoryManageable

Decrement reference count for bounded memory collections

decrementMemoryUsed(ActiveMQMessage) - Method in class org.activemq.io.util.MemoryBoundedMessageCache

 

decrementMemoryUsed(int) - Method in class org.activemq.io.util.MemoryBoundedObjectManager

 

decrementMemoryUsed(MemoryManageable) - Method in class org.activemq.io.util.MemoryBoundedQueue

 

decrementMemoryUsed(int) - Method in class org.activemq.io.util.MemoryBoundedQueueManager

 

deflate(ByteArray) - Method in class org.activemq.io.util.ByteArrayCompression

Deflate the data in the ByteArray

deleteAll() - Method in class org.activemq.io.util.DataContainer

Delete all previous files of the same suffix in the directory

dequeue() - Method in class org.activemq.io.util.MemoryBoundedPrioritizedQueue

 

dequeue() - Method in class org.activemq.io.util.MemoryBoundedQueue

 

dequeue(long) - Method in class org.activemq.io.util.MemoryBoundedQueue

Dequeues a MemoryManageable from the head of the queue

dequeue() - Method in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

 

dequeue(long) - Method in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

 

dequeueNoWait() - Method in class org.activemq.io.util.MemoryBoundedPrioritizedQueue

dequeues a MemoryManageable from the head of the queue

dequeueNoWait() - Method in class org.activemq.io.util.MemoryBoundedQueue

dequeues a MemoryManageable from the head of the queue

dequeueNoWait() - Method in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

 

dir - Variable in class org.activemq.io.util.DataContainer

 

doFragmentation(ByteArray) - Method in class org.activemq.io.util.ByteArrayFragmentation

 

dumpContents() - Method in class org.activemq.io.util.MemoryBoundedQueueManager

 

---

E

enqueue(MemoryManageable) - Method in class org.activemq.io.util.MemoryBoundedQueue

Enqueue a MemoryManageable to this queue

enqueue(ActiveMQMessage) - Method in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

Place a ActiveMQMessage at the head of the Queue

enqueueAllFirstNoBlock(List) - Method in class org.activemq.io.util.MemoryBoundedPrioritizedQueue

Enqueue an array of packets to the head of the queue with total disregard for memory constraints

enqueueAllFirstNoBlock(List) - Method in class org.activemq.io.util.MemoryBoundedQueue

Enqueue an array of packets to the head of the queue with total disregard for memory constraints

enqueueFirst(MemoryManageable) - Method in class org.activemq.io.util.MemoryBoundedQueue

Enqueue a MemoryManageable to the head of the queue

enqueueFirstNoBlock(MemoryManageable) - Method in class org.activemq.io.util.MemoryBoundedPrioritizedQueue

Enqueue a packet to the head of the queue with total disregard for memory constraints

enqueueFirstNoBlock(MemoryManageable) - Method in class org.activemq.io.util.MemoryBoundedQueue

Enqueue a packet to the head of the queue with total disregard for memory constraints

enqueueNoBlock(MemoryManageable) - Method in class org.activemq.io.util.MemoryBoundedPrioritizedQueue

Enqueue a MemoryManageable without checking memory usage limits

enqueueNoBlock(MemoryManageable) - Method in class org.activemq.io.util.MemoryBoundedQueue

Enqueue a MemoryManageable without checking memory usage limits

enqueueNoBlock(ActiveMQMessage) - Method in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

Enqueue a ActiveMQMessage without checking usage limits

entry - Variable in class org.activemq.io.util.MemoryBoundedMessageCache.CacheNode

 

---

F

FileDataBlock - class org.activemq.io.util.FileDataBlock.

Simply writes/reads data from a RandomAccessFile

FileDataBlock(File, long) - Constructor for class org.activemq.io.util.FileDataBlock

Constructor

file - Variable in class org.activemq.io.util.FileDataBlock

 

finalize() - Method in class org.activemq.io.util.MemoryBoundedObjectManager

 

fragment(ByteArray) - Method in class org.activemq.io.util.ByteArrayFragmentation

Fragment a ByteArray into a number of parts

fragmentationLimit - Variable in class org.activemq.io.util.ByteArrayFragmentation

 

---

G

get(int) - Method in class org.activemq.io.util.ByteArray

return the byte at the position

get(String) - Method in class org.activemq.io.util.MemoryBoundedMessageCache

Gets a message that was previously put into this object.

get(int) - Method in class org.activemq.io.util.MemoryBoundedPrioritizedQueue

retrieve a MemoryManageable at an indexed position in the queue

get(int) - Method in class org.activemq.io.util.MemoryBoundedQueue

retrieve a MemoryManageable at an indexed position in the queue

getBuf() - Method in class org.activemq.io.util.ByteArray

 

getCompressionLevel() - Method in class org.activemq.io.util.ByteArrayCompression

 

getCompressionLimit() - Method in class org.activemq.io.util.ByteArrayCompression

 

getCompressionStrategy() - Method in class org.activemq.io.util.ByteArrayCompression

 

getContents() - Method in class org.activemq.io.util.MemoryBoundedPrioritizedQueue

Retrieve a shallow copy of the contents as a list

getContents() - Method in class org.activemq.io.util.MemoryBoundedQueue

Retrieve a shallow copy of the contents as a list

getContents() - Method in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

 

getCurrentCapacity() - Method in class org.activemq.io.util.MemoryBoundedQueueManager

 

getData() - Method in class org.activemq.io.util.WireByteArrayOutputStream

 

getDeflater() - Method in class org.activemq.io.util.WireGZIPOutputStream

 

getFragmentationLimit() - Method in class org.activemq.io.util.ByteArrayFragmentation

 

getGrowthLimit() - Method in class org.activemq.io.util.MemoryBoundedMessageCache

 

getLength() - Method in class org.activemq.io.util.ByteArray

 

getLocalMemoryUsedByThisQueue() - Method in class org.activemq.io.util.MemoryBoundedQueue

 

getMemoryBoundedQueue(String) - Method in class org.activemq.io.util.MemoryBoundedQueueManager

retrieve a named MemoryBoundedQueue or creates one if not found

getMemoryBoundedQueues() - Method in class org.activemq.io.util.MemoryBoundedQueueManager

 

getMemoryId() - Method in interface org.activemq.io.util.MemoryManageable

Get an id that can be used to identify the object.

getMemoryManager() - Method in class org.activemq.io.util.MemoryBoundedQueueManager

 

getMemoryManager() - Method in class org.activemq.io.util.MemoryBoundedQueueTest

 

getMemoryUsage() - Method in interface org.activemq.io.util.MemoryManageable

Get a hint about how much memory this Packet is consuming

getMemoryUsageReferenceCount() - Method in interface org.activemq.io.util.MemoryManageable

 

getName() - Method in class org.activemq.io.util.MemoryBoundedQueue

 

getName() - Method in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

 

getOffset() - Method in class org.activemq.io.util.ByteArray

 

getPacketPriority(MemoryManageable) - Method in class org.activemq.io.util.MemoryBoundedPrioritizedQueue

 

getPercentFull() - Method in class org.activemq.io.util.MemoryBoundedObjectManager

 

getPriority() - Method in interface org.activemq.io.util.MemoryManageable

 

getQueueManager() - Method in class org.activemq.io.util.MemoryBoundedQueueTest

 

getRawData() - Method in class org.activemq.io.util.WireByteArrayInputStream

 

getTotalMemoryUsedSize() - Method in class org.activemq.io.util.MemoryBoundedObjectManager

 

growthLimit - Variable in class org.activemq.io.util.MemoryBoundedMessageCache

 

---

I

inLock - Variable in class org.activemq.io.util.MemoryBoundedQueue

 

inLock - Variable in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

 

incrementMemoryReferenceCount() - Method in interface org.activemq.io.util.MemoryManageable

Increment reference count for bounded memory collections

incrementMemoryUsed(ActiveMQMessage) - Method in class org.activemq.io.util.MemoryBoundedMessageCache

 

incrementMemoryUsed(int) - Method in class org.activemq.io.util.MemoryBoundedObjectManager

 

incrementMemoryUsed(MemoryManageable) - Method in class org.activemq.io.util.MemoryBoundedQueue

 

incrementMemoryUsed(int) - Method in class org.activemq.io.util.MemoryBoundedQueueManager

 

inflate(ByteArray) - Method in class org.activemq.io.util.ByteArrayCompression

Inflate a ByteArray (if it contains compressed data)

internalList - Variable in class org.activemq.io.util.MemoryBoundedQueue

 

isCompressed(ByteArray) - Static method in class org.activemq.io.util.ByteArrayCompression

test for compressed data

isEmpty() - Method in class org.activemq.io.util.DataContainer

 

isEmpty() - Method in class org.activemq.io.util.MemoryBoundedPrioritizedQueue

 

isEmpty() - Method in class org.activemq.io.util.MemoryBoundedQueue

 

isEmpty() - Method in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

 

isEnoughSpace(byte[]) - Method in class org.activemq.io.util.FileDataBlock

test to if there is enough room in the block to write the data

isFull() - Method in class org.activemq.io.util.MemoryBoundedMessageCache

 

isFull() - Method in class org.activemq.io.util.MemoryBoundedObjectManager

 

isFull() - Method in class org.activemq.io.util.MemoryBoundedQueueManager

 

isFull() - Method in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

 

isMemoryLimitEnforced() - Method in class org.activemq.io.util.MemoryBoundedQueueManager

 

isSame(ByteArray, ByteArray) - Method in class org.activemq.io.util.ByteArrayCompressionTest

 

isSame(ByteArray, ByteArray) - Method in class org.activemq.io.util.ByteArrayFragmentationTest

 

isStarted() - Method in class org.activemq.io.util.MemoryBoundedQueue

 

isStarted() - Method in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

 

isSupportJMSPriority() - Method in class org.activemq.io.util.MemoryBoundedObjectManager

 

---

L

length - Variable in class org.activemq.io.util.ByteArray

 

length - Variable in class org.activemq.io.util.DataContainer

 

length() - Method in class org.activemq.io.util.DataContainer

 

localCount - Variable in class org.activemq.io.util.MemoryBoundedQueueTest.Dequeue

 

log - Static variable in class org.activemq.io.util.DataContainer

 

log - Static variable in class org.activemq.io.util.MemoryBoundedPrioritizedQueue

 

log - Static variable in class org.activemq.io.util.MemoryBoundedQueue

 

log - Static variable in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

 

lruList - Variable in class org.activemq.io.util.MemoryBoundedMessageCache

Ordered list of messageIds recently used at the front

---

M

MemoryBoundedMessageCache - class org.activemq.io.util.MemoryBoundedMessageCache.

A simple cache that stores messages in memory.

MemoryBoundedMessageCache(MemoryBoundedObjectManager) - Constructor for class org.activemq.io.util.MemoryBoundedMessageCache

 

MemoryBoundedMessageCache.CacheNode - class org.activemq.io.util.MemoryBoundedMessageCache.CacheNode.

Used associate the a Message to it's QueueListEntry in the lruList

MemoryBoundedMessageCache.CacheNode() - Constructor for class org.activemq.io.util.MemoryBoundedMessageCache.CacheNode

 

MemoryBoundedMessageCacheTest - class org.activemq.io.util.MemoryBoundedMessageCacheTest.

MemoryBoundedQueueTest

MemoryBoundedMessageCacheTest() - Constructor for class org.activemq.io.util.MemoryBoundedMessageCacheTest

 

MemoryBoundedObject - interface org.activemq.io.util.MemoryBoundedObject.

 

MemoryBoundedObjectManager - class org.activemq.io.util.MemoryBoundedObjectManager.

Keeps track of MemoryBoundedObjects

MemoryBoundedObjectManager(String, long) - Constructor for class org.activemq.io.util.MemoryBoundedObjectManager

 

MemoryBoundedObjectManager(String, long, boolean) - Constructor for class org.activemq.io.util.MemoryBoundedObjectManager

 

MemoryBoundedPrioritizedQueue - class org.activemq.io.util.MemoryBoundedPrioritizedQueue.

 

MemoryBoundedPrioritizedQueue(MemoryBoundedQueueManager, String) - Constructor for class org.activemq.io.util.MemoryBoundedPrioritizedQueue

Constructor

MemoryBoundedPrioritizedQueueTest - class org.activemq.io.util.MemoryBoundedPrioritizedQueueTest.

 

MemoryBoundedPrioritizedQueueTest() - Constructor for class org.activemq.io.util.MemoryBoundedPrioritizedQueueTest

 

MemoryBoundedQueue - class org.activemq.io.util.MemoryBoundedQueue.

MemoryBoundedQueue is a queue bounded by memory usage for MemoryManageables

MemoryBoundedQueue(MemoryBoundedQueueManager, String) - Constructor for class org.activemq.io.util.MemoryBoundedQueue

Constructor

MemoryBoundedQueueManager - class org.activemq.io.util.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.

MemoryBoundedQueueManager(MemoryBoundedObjectManager) - Constructor for class org.activemq.io.util.MemoryBoundedQueueManager

 

MemoryBoundedQueueTest - class org.activemq.io.util.MemoryBoundedQueueTest.

MemoryBoundedQueueTest

MemoryBoundedQueueTest() - Constructor for class org.activemq.io.util.MemoryBoundedQueueTest

 

MemoryBoundedQueueTest.Dequeue - class org.activemq.io.util.MemoryBoundedQueueTest.Dequeue.

 

MemoryBoundedQueueTest.Dequeue(MemoryBoundedQueue, int, int) - Constructor for class org.activemq.io.util.MemoryBoundedQueueTest.Dequeue

 

MemoryManageable - interface org.activemq.io.util.MemoryManageable.

 

managedObjects - Variable in class org.activemq.io.util.MemoryBoundedObjectManager

 

manager - Variable in class org.activemq.io.util.MemoryBoundedQueue

 

maxBlockSize - Variable in class org.activemq.io.util.DataContainer

 

maxDataLength - Variable in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

 

maxSize - Variable in class org.activemq.io.util.FileDataBlock

 

memoryLimitEnforced - Variable in class org.activemq.io.util.MemoryBoundedQueueManager

 

memoryManager - Variable in class org.activemq.io.util.MemoryBoundedMessageCache

 

memoryManager - Variable in class org.activemq.io.util.MemoryBoundedMessageCacheTest

 

memoryManager - Variable in class org.activemq.io.util.MemoryBoundedQueueManager

 

memoryManager - Variable in class org.activemq.io.util.MemoryBoundedQueueTest

 

memoryUsedByThisCache - Variable in class org.activemq.io.util.MemoryBoundedMessageCache

 

memoryUsedByThisQueue - Variable in class org.activemq.io.util.MemoryBoundedQueue

 

message - Variable in class org.activemq.io.util.MemoryBoundedMessageCache.CacheNode

 

messages - Variable in class org.activemq.io.util.MemoryBoundedMessageCache

msgId -> LRUNode

---

N

NUMBER_CONSUMERS - Variable in class org.activemq.io.util.MemoryBoundedQueueTest

 

name - Variable in class org.activemq.io.util.DataContainer

 

name - Variable in class org.activemq.io.util.MemoryBoundedQueue

 

name - Variable in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

 

---

O

OBJECT_OVERHEAD - Static variable in class org.activemq.io.util.MemoryBoundedMessageCache

 

OBJECT_OVERHEAD - Static variable in class org.activemq.io.util.MemoryBoundedQueue

 

offset - Variable in class org.activemq.io.util.ByteArray

 

org.activemq.io.util - package org.activemq.io.util

 

outLock - Variable in class org.activemq.io.util.MemoryBoundedQueue

 

outLock - Variable in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

 

---

P

position() - Method in class org.activemq.io.util.WireByteArrayInputStream

 

prioritizedPackets - Variable in class org.activemq.io.util.MemoryBoundedPrioritizedQueue

 

put(String, ActiveMQMessage) - Method in class org.activemq.io.util.MemoryBoundedMessageCache

Puts a message into the cache.

---

Q

QUEUE_NAME - Static variable in class org.activemq.io.util.MemoryBoundedQueueTest

 

queue - Variable in class org.activemq.io.util.MemoryBoundedQueueTest.Dequeue

 

queueManager - Variable in class org.activemq.io.util.MemoryBoundedQueueTest

 

---

R

read() - Method in class org.activemq.io.util.DataContainer

read a block of data from the container

read() - Method in class org.activemq.io.util.FileDataBlock

read next chunk of data

read() - Method in class org.activemq.io.util.WireByteArrayInputStream

Reads the next byte of data from this input stream.

read(byte[], int, int) - Method in class org.activemq.io.util.WireByteArrayInputStream

Reads up to len bytes of data into an array of bytes from this input stream.

readBlock - Variable in class org.activemq.io.util.DataContainer

 

remove(String) - Method in class org.activemq.io.util.MemoryBoundedMessageCache

Remvoes a message from the cache.

remove(MemoryBoundedObject) - Method in class org.activemq.io.util.MemoryBoundedObjectManager

 

remove(MemoryManageable) - Method in class org.activemq.io.util.MemoryBoundedPrioritizedQueue

Remove a packet from the queue

remove(Object) - Method in class org.activemq.io.util.MemoryBoundedPrioritizedQueue

Remove a MemoryManageable by it's id

remove(MemoryManageable) - Method in class org.activemq.io.util.MemoryBoundedQueue

Remove a packet from the queue

remove(Object) - Method in class org.activemq.io.util.MemoryBoundedQueue

Remove a MemoryManageable by it's id

remove(MemoryBoundedQueue) - Method in class org.activemq.io.util.MemoryBoundedQueueManager

 

removeOldest() - Method in class org.activemq.io.util.MemoryBoundedMessageCache

 

reset(byte[]) - Method in class org.activemq.io.util.ByteArray

reset values

reset(byte[], int, int) - Method in class org.activemq.io.util.ByteArray

reset values

reset() - Method in class org.activemq.io.util.WireByteArrayOutputStream

reset the output stream

restart(byte[], int, int) - Method in class org.activemq.io.util.WireByteArrayInputStream

reset the WireByteArrayInputStream to use an new byte array

restart(byte[]) - Method in class org.activemq.io.util.WireByteArrayInputStream

reset the WireByteArrayInputStream to use an new byte array

restart(int) - Method in class org.activemq.io.util.WireByteArrayOutputStream

start using a fresh byte array

restart() - Method in class org.activemq.io.util.WireByteArrayOutputStream

start using a fresh byte array

run() - Method in class org.activemq.io.util.MemoryBoundedQueueTest.Dequeue

 

---

S

SUFFIX - Static variable in class org.activemq.io.util.DataContainer

 

SpooledBoundedActiveMQMessageQueue - class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue.

Implements a controlled thread safe queue, with ActiveMQMessages being spooled to disk for reading asynchronously.

SpooledBoundedActiveMQMessageQueue(File, String, long, int) - Constructor for class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

Constructor for SpooledBoundedActiveMQMessageQueue

SpooledBoundedActiveMQMessageQueue(File, String) - Constructor for class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

Constructor for SpooledBoundedActiveMQMessageQueue

sequence - Variable in class org.activemq.io.util.DataContainer

 

setBuf(byte[]) - Method in class org.activemq.io.util.ByteArray

 

setCompressionLevel(int) - Method in class org.activemq.io.util.ByteArrayCompression

 

setCompressionLimit(int) - Method in class org.activemq.io.util.ByteArrayCompression

 

setCompressionStrategy(int) - Method in class org.activemq.io.util.ByteArrayCompression

 

setFragmentationLimit(int) - Method in class org.activemq.io.util.ByteArrayFragmentation

 

setGrowthLimit(float) - Method in class org.activemq.io.util.MemoryBoundedMessageCache

 

setLength(int) - Method in class org.activemq.io.util.ByteArray

 

setMemoryLimitEnforced(boolean) - Method in class org.activemq.io.util.MemoryBoundedQueueManager

 

setOffset(int) - Method in class org.activemq.io.util.ByteArray

 

setSupportJMSPriority(boolean) - Method in class org.activemq.io.util.MemoryBoundedObjectManager

 

setUp() - Method in class org.activemq.io.util.ByteArrayCompressionTest

 

setUp() - Method in class org.activemq.io.util.ByteArrayFragmentationTest

 

setUp() - Method in class org.activemq.io.util.MemoryBoundedPrioritizedQueueTest

 

size - Variable in class org.activemq.io.util.DataContainer

 

size() - Method in class org.activemq.io.util.DataContainer

 

size() - Method in class org.activemq.io.util.MemoryBoundedPrioritizedQueue

 

size() - Method in class org.activemq.io.util.MemoryBoundedQueue

 

size - Variable in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

 

size() - Method in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

 

start() - Method in class org.activemq.io.util.MemoryBoundedQueue

enable dequeueing

start() - Method in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

enable dequeueing

stop() - Method in class org.activemq.io.util.MemoryBoundedQueue

disable dequeueing

stop() - Method in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

disable dequeueing

stopped - Variable in class org.activemq.io.util.MemoryBoundedQueue

 

stopped - Variable in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

 

stoppedSemaphore - Variable in class org.activemq.io.util.MemoryBoundedQueueTest

 

supportJMSPriority - Variable in class org.activemq.io.util.MemoryBoundedObjectManager

 

supportJMSPriority - Variable in class org.activemq.io.util.MemoryBoundedQueueTest

 

---

T

TEST_ENQUEUE_SIZE - Static variable in class org.activemq.io.util.MemoryBoundedQueueTest

 

TEST_INSTANCE_SIZE - Static variable in class org.activemq.io.util.MemoryBoundedMessageCacheTest

 

TEST_INSTANCE_SIZE - Static variable in class org.activemq.io.util.MemoryBoundedQueueTest

 

TOTAL_LOAD - Variable in class org.activemq.io.util.MemoryBoundedQueueTest

 

tearDown() - Method in class org.activemq.io.util.ByteArrayCompressionTest

 

tearDown() - Method in class org.activemq.io.util.ByteArrayFragmentationTest

 

testClear() - Method in class org.activemq.io.util.MemoryBoundedQueueTest

 

testClose() - Method in class org.activemq.io.util.MemoryBoundedQueueTest

 

testCompression() - Method in class org.activemq.io.util.ByteArrayCompressionTest

 

testData - Variable in class org.activemq.io.util.ByteArrayCompressionTest

 

testData - Variable in class org.activemq.io.util.ByteArrayFragmentationTest

 

testDequeue() - Method in class org.activemq.io.util.MemoryBoundedQueueTest

 

testDequeueNoWait() - Method in class org.activemq.io.util.MemoryBoundedQueueTest

 

testDoFragmentation() - Method in class org.activemq.io.util.ByteArrayFragmentationTest

 

testEnqueueFirst() - Method in class org.activemq.io.util.MemoryBoundedQueueTest

 

testEnqueueNoBlock() - Method in class org.activemq.io.util.MemoryBoundedQueueTest

 

testIsEmpty() - Method in class org.activemq.io.util.MemoryBoundedQueueTest

 

testLoad() - Method in class org.activemq.io.util.MemoryBoundedQueueTest

 

testMemoryGrowth() - Method in class org.activemq.io.util.MemoryBoundedMessageCacheTest

 

testMemoryLimiting() - Method in class org.activemq.io.util.MemoryBoundedMessageCacheTest

 

testMessagePriority() - Method in class org.activemq.io.util.MemoryBoundedPrioritizedQueueTest

 

testRemove() - Method in class org.activemq.io.util.MemoryBoundedQueueTest

 

testRemovePacket() - Method in class org.activemq.io.util.MemoryBoundedQueueTest

 

testRemovePacketById() - Method in class org.activemq.io.util.MemoryBoundedQueueTest

 

testSize() - Method in class org.activemq.io.util.MemoryBoundedQueueTest

 

testString - Variable in class org.activemq.io.util.ByteArrayFragmentationTest

 

toString() - Method in class org.activemq.io.util.MemoryBoundedQueue

 

totalMemoryUsedSize - Variable in class org.activemq.io.util.MemoryBoundedObjectManager

 

---

U

updateHeader(long) - Method in class org.activemq.io.util.FileDataBlock

 

---

W

WAIT_TIMEOUT - Static variable in class org.activemq.io.util.MemoryBoundedQueue

 

WAIT_TIMEOUT - Static variable in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

 

WireByteArrayInputStream - class org.activemq.io.util.WireByteArrayInputStream.

Optimized ByteArrayInputStream that can be used more than once.

WireByteArrayInputStream(byte[]) - Constructor for class org.activemq.io.util.WireByteArrayInputStream

Creates a WireByteArrayInputStream.

WireByteArrayInputStream(byte[], int, int) - Constructor for class org.activemq.io.util.WireByteArrayInputStream

Creates WireByteArrayInputStream that uses buf as its buffer array.

WireByteArrayInputStream(ByteArray) - Constructor for class org.activemq.io.util.WireByteArrayInputStream

Create a WireByteArrayInputStream that uses a ByteArray

WireByteArrayInputStream() - Constructor for class org.activemq.io.util.WireByteArrayInputStream

Creates WireByteArrayInputStream with a minmalist byte array

WireByteArrayOutputStream - class org.activemq.io.util.WireByteArrayOutputStream.

Optimized ByteArrayOutputStream

WireByteArrayOutputStream() - Constructor for class org.activemq.io.util.WireByteArrayOutputStream

Creates a new byte array output stream.

WireByteArrayOutputStream(int) - Constructor for class org.activemq.io.util.WireByteArrayOutputStream

Creates a new byte array output stream, with a buffer capacity of the specified size, in bytes.

WireGZIPOutputStream - class org.activemq.io.util.WireGZIPOutputStream.

Compression stream

WireGZIPOutputStream(OutputStream) - Constructor for class org.activemq.io.util.WireGZIPOutputStream

Compression stream

wireFormat - Variable in class org.activemq.io.util.SpooledBoundedActiveMQMessageQueue

 

write(byte[]) - Method in class org.activemq.io.util.DataContainer

write a block of data into the Container

write(byte[]) - Method in class org.activemq.io.util.FileDataBlock

Write data to the end of the block

write(int) - Method in class org.activemq.io.util.WireByteArrayOutputStream

Writes the specified byte to this byte array output stream.

write(byte[], int, int) - Method in class org.activemq.io.util.WireByteArrayOutputStream

Writes len bytes from the specified byte array starting at offset off to this byte array output stream.

writeBlock - Variable in class org.activemq.io.util.DataContainer

 

---

A B C D E F G I L M N O P Q R S T U W

Overview  Package  Class  Use  Deprecated   Index
Home >> All >> org >> activemq >> io >> [ util overview ]	PREV  NEXT

---