Class JESpace<K,V>

java.lang.Object

org.jpos.util.Log

org.jpos.space.JESpace<K,V>

All Implemented Interfaces:

AutoCloseable, Runnable, LocalSpace<K,V>, PersistentSpace, Space<K,V>, Loggeable, LogSource

public class JESpace<K,V>
extends Log
implements LocalSpace<K,V>, PersistentSpace, Loggeable, Runnable

BerkeleyDB Jave Edition based persistent space implementation

Since:

1.6.5

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JESpace.GCRef
static class	JESpace.Ref

Field Summary

Fields

Modifier and Type	Field	Description
static final long	DEFAULT_LOCK_TIMEOUT
static final long	DEFAULT_TXN_TIMEOUT
static final long	GC_DELAY

Fields inherited from class Log

DEBUG, ERROR, FATAL, INFO, logger, realm, TRACE, WARN

Constructor Summary

Constructors

Constructor	Description
JESpace(String name, String params)

Method Summary

Modifier and Type	Method	Description
void	addListener(Object key, SpaceListener listener)	add a SpaceListener associated with a given key
void	addListener(Object key, SpaceListener listener, long timeout)	add a SpaceListener associated with a given key for a given period of time.
void	close()
void	dump(PrintStream p, String indent)
boolean	existAny(Object[] keys)
boolean	existAny(Object[] keys, long timeout)
void	gc()
Set	getKeySet()
static JESpace	getSpace(String name)
static JESpace	getSpace(String name, String path)
V	in(Object key)	Take an entry from the space, waiting forever until one exists.
V	in(Object key, long timeout)	Take an entry from the space, waiting a limited amount of time until one exists.
V	inp(Object key)	In probe takes an entry from the space if one exists, return null otherwise.
void	nrd(Object key)	Nrd (not read) waits forever until Key is not present in space. Resolution for expiring entries is implementation dependant, but a minimum one-second is suggested.
V	nrd(Object key, long timeout)	Nrd (not read) waits up to timeout until Key is not present in space. Resolution for expiring entries is implementation dependant, but a minimum one-second is suggested.
void	out(K key, V value)	Write a new entry into the Space
void	out(K key, V value, long timeout)	Write a new entry into the Space, with an timeout value
void	push(K key, V value)	Write a new entry at the head of a queue.
void	push(K key, V value, long timeout)	Write a new entry at the head of the queue with a timeout value
void	put(K key, V value)	Write a single entry at the head of the queue discarding the other entries
void	put(K key, V value, long timeout)	Write a single entry at the head of the queue discarding the other entries, with timeout.
V	rd(Object key)	Read an entry from the space, waiting forever until one exists.
V	rd(Object key, long timeout)	Read an entry from the space, waiting a limited amount of time until one exists.
V	rdp(Object key)	Read probe reads an entry from the space if one exists, return null otherwise.
void	removeListener(Object key, SpaceListener listener)	removes a SpaceListener associated with a given key
void	run()
int	size(Object key)

Methods inherited from class Log

createDebug, createDebug, createError, createError, createFatal, createFatal, createInfo, createInfo, createLogEvent, createLogEvent, createTrace, createTrace, createWarn, createWarn, debug, debug, error, error, fatal, fatal, getLog, getLogger, getRealm, info, info, setLogger, setLogger, setRealm, trace, trace, warn, warn

Methods inherited from class Object

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

Methods inherited from interface Loggeable

dump

Field Details

GC_DELAY

public static final long GC_DELAY

See Also:

• Constant Field Values

DEFAULT_TXN_TIMEOUT

public static final long DEFAULT_TXN_TIMEOUT

See Also:

• Constant Field Values

DEFAULT_LOCK_TIMEOUT

public static final long DEFAULT_LOCK_TIMEOUT

See Also:

• Constant Field Values

Constructor Details

JESpace

public JESpace(String name,
 String params)
        throws SpaceError

Throws:

SpaceError

Method Details

out

public void out(K key,
 V value)

Description copied from interface: Space

Write a new entry into the Space

Specified by:

out in interface Space<K,V>

Parameters:

key - Entry's key

value - Object value

out

public void out(K key,
 V value,
 long timeout)

Description copied from interface: Space

Write a new entry into the Space, with an timeout value

Specified by:

out in interface Space<K,V>

Parameters:

key - Entry's key

value - Object value

timeout - timeout value in millis

push

public void push(K key,
 V value,
 long timeout)

Description copied from interface: Space

Write a new entry at the head of the queue with a timeout value

Specified by:

push in interface Space<K,V>

Parameters:

key - Entry's key

value - Object value

timeout - timeout value in millis

push

public void push(K key,
 V value)

Description copied from interface: Space

Write a new entry at the head of a queue.

Specified by:

push in interface Space<K,V>

Parameters:

key - Entry's key

value - Object value

rdp

public V rdp(Object key)

Description copied from interface: Space

Read probe reads an entry from the space if one exists, return null otherwise.

Specified by:

rdp in interface Space<K,V>

Parameters:

key - Entry's key

Returns:

value or null

in

public V in(Object key)

Description copied from interface: Space

Take an entry from the space, waiting forever until one exists.

Specified by:

in in interface Space<K,V>

Parameters:

key - Entry's key

Returns:

value

in

public V in(Object key,
 long timeout)

Description copied from interface: Space

Take an entry from the space, waiting a limited amount of time until one exists.

Specified by:

in in interface Space<K,V>

Parameters:

key - Entry's key

timeout - millis to wait

Returns:

value or null

rd

public V rd(Object key)

Description copied from interface: Space

Read an entry from the space, waiting forever until one exists.

Specified by:

rd in interface Space<K,V>

Parameters:

key - Entry's key

Returns:

value

rd

public V rd(Object key,
 long timeout)

Description copied from interface: Space

Read an entry from the space, waiting a limited amount of time until one exists.

Specified by:

rd in interface Space<K,V>

Parameters:

key - Entry's key

timeout - millis to wait

Returns:

value or null

nrd

public void nrd(Object key)

Description copied from interface: Space

Nrd (not read) waits forever until Key is not present in space.
Resolution for expiring entries is implementation dependant, but a minimum one-second is suggested.

Specified by:

nrd in interface Space<K,V>

Parameters:

key - Entry's key

nrd

public V nrd(Object key,
 long timeout)

Description copied from interface: Space

Nrd (not read) waits up to timeout until Key is not present in space.
Resolution for expiring entries is implementation dependant, but a minimum one-second is suggested.

Specified by:

nrd in interface Space<K,V>

Parameters:

key - Entry's key

timeout - millis to wait

Returns:

value or null

inp

public V inp(Object key)

Description copied from interface: Space

In probe takes an entry from the space if one exists, return null otherwise.

Specified by:

inp in interface Space<K,V>

Parameters:

key - Entry's key

Returns:

value or null

existAny

public boolean existAny(Object[] keys)

Specified by:

existAny in interface Space<K,V>

Parameters:

keys - array of keys to check

Returns:

true if one or more keys are available in the space

existAny

public boolean existAny(Object[] keys,
 long timeout)

Specified by:

existAny in interface Space<K,V>

Parameters:

keys - array of keys to check

timeout - to wait for any of the entries to become available in millis

Returns:

true if one or more keys are available in the space

put

public void put(K key,
 V value,
 long timeout)

Description copied from interface: Space

Write a single entry at the head of the queue discarding the other entries, with timeout.

Specified by:

put in interface Space<K,V>

Parameters:

key - Entry's key

value - Object value

timeout - timeout value in millis

put

public void put(K key,
 V value)

Description copied from interface: Space

Write a single entry at the head of the queue discarding the other entries

Specified by:

put in interface Space<K,V>

Parameters:

key - Entry's key

value - Object value

gc

public void gc()
        throws com.sleepycat.je.DatabaseException

Throws:

com.sleepycat.je.DatabaseException

run

public void run()

Specified by:

run in interface Runnable

close

public void close()
           throws com.sleepycat.je.DatabaseException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Space<K,V>

Throws:

com.sleepycat.je.DatabaseException

getSpace

public static JESpace getSpace(String name,
 String path)

getSpace

public static JESpace getSpace(String name)

addListener

public void addListener(Object key,
 SpaceListener listener)

Description copied from interface: LocalSpace

add a SpaceListener associated with a given key

Specified by:

addListener in interface LocalSpace<K,V>

Parameters:

key - Entry's key

listener - a SpaceListener

addListener

public void addListener(Object key,
 SpaceListener listener,
 long timeout)

Description copied from interface: LocalSpace

add a SpaceListener associated with a given key for a given period of time. Warning: not supported by all space implementations.

Specified by:

addListener in interface LocalSpace<K,V>

Parameters:

key - Entry's key

listener - a SpaceListener

timeout - listener registration timeout in millis

removeListener

public void removeListener(Object key,
 SpaceListener listener)

Description copied from interface: LocalSpace

removes a SpaceListener associated with a given key

Specified by:

removeListener in interface LocalSpace<K,V>

Parameters:

key - Entry's key

listener - the SpaceListener

getKeySet

public Set getKeySet()

Specified by:

getKeySet in interface LocalSpace<K,V>

Returns:

Set containing all keys in Space

size

public int size(Object key)

Specified by:

size in interface LocalSpace<K,V>

Returns:

number of entries in a given key

dump

public void dump(PrintStream p,
 String indent)

Specified by:

dump in interface Loggeable