Uses of Class
com.swiftmq.impl.streams.comp.memory.Memory

Packages that use Memory

Package	Description
com.swiftmq.impl.streams
com.swiftmq.impl.streams.comp.jdbc
com.swiftmq.impl.streams.comp.memory
com.swiftmq.impl.streams.comp.memory.limit

Uses of Memory in com.swiftmq.impl.streams

Methods in com.swiftmq.impl.streams that return Memory

Modifier and Type	Method	Description
Memory	Stream.addMemory(String name, Memory memory)	Internal use only
Memory[]	Stream.getMemories()	Internal use only
Memory	Stream.memory(String name)	Returns the Memory with the given name.
Memory	Stream.stateMemory()	Returns the Stream's State Memory that is used by MemoryGroups to store their associated Memories.

Methods in com.swiftmq.impl.streams with parameters of type Memory

Modifier and Type	Method	Description
Memory	Stream.addMemory(String name, Memory memory)	Internal use only
void	Stream.removeMemory(Memory memory)	Internal use only

Uses of Memory in com.swiftmq.impl.streams.comp.jdbc

Methods in com.swiftmq.impl.streams.comp.jdbc that return Memory

Modifier and Type	Method	Description
Memory	JDBCLookup.query(String sql)	Performs a select query and returns a Memory with the result.
static Memory	Util.query(Stream stream, Connection connection, String sql)

Uses of Memory in com.swiftmq.impl.streams.comp.memory

Subclasses of Memory in com.swiftmq.impl.streams.comp.memory

Modifier and Type	Class	Description
class	HeapMemory	Memory implementation that stores all Messages on the heap.
class	QueueMemory	Memory implementation that stores all Messages as persistent Messages in a regular Queue.
class	TempQueueMemory	Memory implementation that stores all Messages as non-persistent Messages in a Temporary Queue.

Methods in com.swiftmq.impl.streams.comp.memory that return Memory

Modifier and Type	Method	Description
Memory	HeapMemory.add(Message message)
abstract Memory	Memory.add(Message message)	Add a Message to the Memory.
Memory	QueueMemory.add(Message message)
Memory	GroupResult.average(String propName)	Determines the average value of a Property and returns the result as a new non-queue Memory with Messages that contains 2 Properties, the grouping Property and the average Property.
Memory	Memory.checkLimit()	Checks the limit of the Memory and retires Messages, if necessary.
Memory	HeapMemory.clear()
abstract Memory	Memory.clear()	Removes all Messages from this Memory.
Memory	QueueMemory.clear()
Memory	MemoryCreateCallback.create(Comparable key)	Create a new Memory
Memory	Memory.createIndex(String propName)	Creates an Index over a Property
Memory	Memory.dropLateArrivals(boolean dropLateArrivals)	Specifies whether late arrivals should be dropped (default is false).
Memory	Index.get(Object value)	Selects all Messages with a specific Property Value from the associated Memory and returns the result as new non-queue Memory.
Memory	Memory.join(Memory right, String joinProp)	Performs an inner join with the right Memory over the named join Property name which must exists in the Messages of both Memories.
Memory	Memory.join(Memory right, String leftJoinProp, String rightJoinProp)	Performs an inner join with the right Memory.
Memory	GroupResult.max(String propName)	Determines the maximum value of a Property and returns the result as a new non-queue Memory with Messages that contains 2 Properties, the grouping Property and the maximum Property.
Memory	GroupResult.min(String propName)	Determines the minimum value of a Property and returns the result as a new non-queue Memory with Messages that contains 2 Properties, the grouping Property and the minimum Property.
Memory	Memory.onRetire(RetirementCallback callback)	Sets a callback which is called for each Message that is retired (removed by a Limit).
Memory	Memory.orderBy(String orderByProperty)	Sets the Property name that is used to order this Memory.
Memory	HeapMemory.remove(int index)
Memory	HeapMemory.remove(String selector)
abstract Memory	Memory.remove(int index)	Removes the Message at the index.
abstract Memory	Memory.remove(String selector)	Removes all Messages from this Memory that matches the JMS message selector and returns this Memory.
Memory	QueueMemory.remove(int index)
Memory	QueueMemory.remove(String selector)
Memory	HeapMemory.removeOlderThan(long time)
Memory	HeapMemory.removeOlderThan(long time, boolean executeCallback)
abstract Memory	Memory.removeOlderThan(long time)	Removes all Messages with a store time older than time.
abstract Memory	Memory.removeOlderThan(long time, boolean executeCallback)	Internal use.
Memory	QueueMemory.removeOlderThan(long time)
Memory	QueueMemory.removeOlderThan(long time, boolean executeCallback)
Memory[]	GroupResult.result()	Returns the result as an array of Memories.
Memory	Memory.reverse()	Reverses the Message order of this Memory and returns a new Memory with the result.
Memory	HeapMemory.select(String selector)
abstract Memory	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.
Memory	QueueMemory.select(String selector)
Memory	Memory.sort(String propName)	Sorts all Messages of this Memory over a Property and returns a new Memory with the result.
Memory	GroupResult.sum(String propName)	Determines the sum of all values of a Property and returns the result as a new non-queue Memory with Messages that contains 2 Properties, the grouping Property and the sum Property.

Methods in com.swiftmq.impl.streams.comp.memory with parameters of type Memory

Modifier and Type	Method	Description
void	ForEachMemoryCallback.execute(Memory memory)	Single method to be executed for each Memory of a MemoryGroup
void	RetirementCallback.execute(Memory memory)	Single method which is called during Memory.checkLimit().
Memory	Memory.join(Memory right, String joinProp)	Performs an inner join with the right Memory over the named join Property name which must exists in the Messages of both Memories.
Memory	Memory.join(Memory right, String leftJoinProp, String rightJoinProp)	Performs an inner join with the right Memory.

Uses of Memory in com.swiftmq.impl.streams.comp.memory.limit

Constructors in com.swiftmq.impl.streams.comp.memory.limit with parameters of type Memory

Modifier	Constructor	Description
	LimitBuilder(StreamContext ctx, Memory memory)	Internal use only.
	TimeUnitChangeLimit(StreamContext ctx, Memory memory)	Internal use only.