org.jpos.space
Class TinySpace

java.lang.Object
  org.jpos.space.TinySpace

All Implemented Interfaces:

java.io.Serializable, Space

Direct Known Subclasses:

Request

public class TinySpace
extends java.lang.Object
implements Space, java.io.Serializable

Tiny Space implementation

Since:

1.4.7

Version:

$Revision: 2776 $ $Date: 2009-09-18 18:53:31 -0700 (Fri, 18 Sep 2009) $

Author:

Alejandro Revilla

See Also:

Serialized Form

Constructor Summary

TinySpace()

Method Summary

boolean	existAny(java.lang.Object[] keys)
boolean	existAny(java.lang.Object[] keys, long timeout)
java.lang.Object	in(java.lang.Object key) Take an entry from the space, waiting forever until one exists.
java.lang.Object	in(java.lang.Object key, long timeout) Take an entry from the space, waiting a limited amount of time until one exists.
java.lang.Object	inp(java.lang.Object key) In probe takes an entry from the space if one exists, return null otherwise.
void	out(java.lang.Object key, java.lang.Object value) Write a new entry into the Space
void	out(java.lang.Object id, java.lang.Object value, long timeout) Write a new entry into the Space, with an timeout value
void	push(java.lang.Object id, java.lang.Object value) Write a new entry at the head of a queue.
void	push(java.lang.Object id, java.lang.Object value, long timeout) Write a new entry at the head of the queue with a timeout value
java.lang.Object	rd(java.lang.Object key) Read an entry from the space, waiting forever until one exists.
java.lang.Object	rd(java.lang.Object key, long timeout) Read an entry from the space, waiting a limited amount of time until one exists.
java.lang.Object	rdp(java.lang.Object key) Read probe reads an entry from the space if one exists, return null otherwise.

Methods inherited from class java.lang.Object

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

Constructor Detail

TinySpace

public TinySpace()

Method Detail

out

public void out(java.lang.Object key,
                java.lang.Object value)

Description copied from interface: Space

Write a new entry into the Space

Specified by:

out in interface Space

Parameters:

key - Entry's key

value - Object value

out

public void out(java.lang.Object id,
                java.lang.Object 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

Parameters:

id - Entry's key

value - Object value

timeout - timeout value

rdp

public java.lang.Object rdp(java.lang.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

Parameters:

key - Entry's key

Returns:

value or null

inp

public java.lang.Object inp(java.lang.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

Parameters:

key - Entry's key

Returns:

value or null

in

public java.lang.Object in(java.lang.Object key)

Description copied from interface: Space

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

Specified by:

in in interface Space

Parameters:

key - Entry's key

Returns:

value

in

public java.lang.Object in(java.lang.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

Parameters:

key - Entry's key

timeout - millis to wait

Returns:

value or null

rd

public java.lang.Object rd(java.lang.Object key)

Description copied from interface: Space

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

Specified by:

rd in interface Space

Parameters:

key - Entry's key

Returns:

value

rd

public java.lang.Object rd(java.lang.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

Parameters:

key - Entry's key

timeout - millis to wait

Returns:

value or null

existAny

public boolean existAny(java.lang.Object[] keys)

Specified by:

existAny in interface Space

Parameters:

keys - array of keys to check

Returns:

true if one or more keys are available in the space

existAny

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

Specified by:

existAny in interface Space

Parameters:

keys - array of keys to check

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

Returns:

true if one or more keys are available in the space

push

public void push(java.lang.Object id,
                 java.lang.Object value)

Description copied from interface: Space

Write a new entry at the head of a queue.

Specified by:

push in interface Space

Parameters:

id - Entry's key

value - Object value

push

public void push(java.lang.Object id,
                 java.lang.Object 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

Parameters:

id - Entry's key

value - Object value

timeout - timeout value