Package com.swiftmq.impl.streams.comp.memory

Class HeapMemory

java.lang.Object

com.swiftmq.impl.streams.comp.memory.Memory

com.swiftmq.impl.streams.comp.memory.HeapMemory

public class HeapMemory
extends Memory

Memory implementation that stores all Messages on the heap.

Author:

IIT Software GmbH, Muenster/Germany, (c) 2016, All Rights Reserved

Nested Class Summary

Nested classes/interfaces inherited from class com.swiftmq.impl.streams.comp.memory.Memory

Memory.Entry

Constructor Summary

Constructors

Constructor	Description
HeapMemory(StreamContext ctx)

Method Summary

Modifier and Type	Method	Description
Memory	add(Message message)	Add a Message to the Memory.
Message	at(int index)	Returns the Message at the index.
Memory	clear()	Removes all Messages from this Memory.
void	deferredClose()	Internal use.
long	getStoreTime(int index)	Internal use.
void	reload()	Internal use.
Memory	remove(int index)	Removes the Message at the index.
Memory	remove(String selector)	Removes all Messages from this Memory that matches the JMS message selector and returns this Memory.
Memory	removeOlderThan(long time)	Removes all Messages with a store time older than time.
Memory	removeOlderThan(long time, boolean executeCallback)	Internal use.
Memory	select(String selector)	Applies a JMS message selector to all Messages in this Memory and returns a new non-queue Memory with the result.
int	size()	Returns the number of Messages stored in this Memory.
String	toString()

Methods inherited from class com.swiftmq.impl.streams.comp.memory.Memory

addLimit, addToIndexes, ascendingSeries, average, checkLimit, clearIndexes, close, collect, createIndex, descendingSeries, dropLateArrivals, first, forEach, getStoreTime, getStoreTimes, group, inactivityTimeout, index, isLate, isMarkedAsClose, join, join, last, limit, max, min, name, newKey, onRetire, orderBy, orderBy, removeFromIndexes, retirementCallback, reverse, sort, sum, values

Methods inherited from class java.lang.Object

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

Constructor Details

HeapMemory

public HeapMemory(StreamContext ctx)

Method Details

reload

public void reload()
            throws Exception

Description copied from class: Memory

Internal use.

Specified by:

reload in class Memory

Throws:

Exception

add

public Memory add(Message message)
           throws Exception

Description copied from class: Memory

Add a Message to the Memory.

Specified by:

add in class Memory

Parameters:

message - Message

Returns:

Memory

Throws:

Exception

remove

public Memory remove(int index)
              throws Exception

Description copied from class: Memory

Removes the Message at the index.

Specified by:

remove in class Memory

Parameters:

index - index

Returns:

Memory

Throws:

Exception

removeOlderThan

public Memory removeOlderThan(long time)
                       throws Exception

Description copied from class: Memory

Removes all Messages with a store time older than time.

Specified by:

removeOlderThan in class Memory

Parameters:

time - Time

Returns:

Memory

Throws:

Exception

removeOlderThan

public Memory removeOlderThan(long time,
 boolean executeCallback)
                       throws Exception

Description copied from class: Memory

Internal use.

Specified by:

removeOlderThan in class Memory

Throws:

Exception

at

public Message at(int index)
           throws Exception

Description copied from class: Memory

Returns the Message at the index.

Specified by:

at in class Memory

Parameters:

index - index

Returns:

Message

Throws:

Exception

getStoreTime

public long getStoreTime(int index)

Description copied from class: Memory

Internal use.

Specified by:

getStoreTime in class Memory

size

public int size()
         throws Exception

Description copied from class: Memory

Returns the number of Messages stored in this Memory.

Specified by:

size in class Memory

Returns:

Number Messages

Throws:

Exception

clear

public Memory clear()
             throws Exception

Description copied from class: Memory

Removes all Messages from this Memory.

Specified by:

clear in class Memory

Returns:

Memory

Throws:

Exception

deferredClose

public void deferredClose()

Description copied from class: Memory

Internal use.

Overrides:

deferredClose in class Memory

select

public Memory select(String selector)
              throws Exception

Description copied from class: Memory

Applies a JMS message selector to all Messages in this Memory and returns a new non-queue Memory with the result.

Specified by:

select in class Memory

Parameters:

selector - JMS Message Selector

Returns:

Result

Throws:

Exception

remove

public Memory remove(String selector)
              throws Exception

Description copied from class: Memory

Removes all Messages from this Memory that matches the JMS message selector and returns this Memory.

Specified by:

remove in class Memory

Parameters:

selector - JMS Message Selector

Returns:

Memory (this)

Throws:

Exception

toString

public String toString()

Overrides:

toString in class Object