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

Class MemoryBuilder

java.lang.Object

com.swiftmq.impl.streams.comp.memory.MemoryBuilder

public class MemoryBuilder
extends Object

Factory to create Memories.

Author:

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

Constructor Summary

Constructors

Constructor	Description
MemoryBuilder(StreamContext ctx, String name)	Internal use.

Method Summary

Modifier and Type	Method	Description
HeapMemory	heap()	Creates a Memory that stores Messages on the Heap
QueueMemory	queue(String queueName)	Creates a Memory that stores Messages in a regular Queue
QueueMemory	sharedQueue(String queueName)	Creates a Memory that stores Messages in a regular Queue and shared that Queue with other QueueMemories of the same Stream
TempQueueMemory	tempqueue()	Creates a Memory that stores Messages in a Temporary Queue

Methods inherited from class java.lang.Object

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

Constructor Details

MemoryBuilder

public MemoryBuilder(StreamContext ctx,
 String name)

Internal use.

Method Details

heap

public HeapMemory heap()

Creates a Memory that stores Messages on the Heap

Returns:

HeapMemory

queue

public QueueMemory queue(String queueName)
                  throws Exception

Creates a Memory that stores Messages in a regular Queue

Parameters:

queueName - Queue that serves as a persistent store

Returns:

QueueMemory

Throws:

Exception

sharedQueue

public QueueMemory sharedQueue(String queueName)
                        throws Exception

Creates a Memory that stores Messages in a regular Queue and shared that Queue with other QueueMemories of the same Stream

Parameters:

queueName - Queue that serves as a shared persistent store

Returns:

QueueMemory

Throws:

Exception

tempqueue

public TempQueueMemory tempqueue()
                          throws Exception

Creates a Memory that stores Messages in a Temporary Queue

Returns:

TempQueueMemory

Throws:

Exception