tango.net.cluster.tina.ClusterQueue

License:

BSD style: see license.txt

Version:

July 2004: Initial release

Author:

Kris

class ClusterQueue ¶#

void watchdog() [abstract] ¶#

ClusterContent get(char[] name) [abstract] ¶#

bool put(char[] name, ClusterContent content) [abstract] ¶#

this(Cluster cluster, uint limit, double sleep) ¶#

void publish(IChannel channel) [final] ¶#

void run() [private] ¶#

class PersistQueue : ClusterQueue ¶#

this(Cluster cluster, uint limit, double sleep) ¶#

QueueFile lookup(char[] name) [synchronized, final] ¶#

bool put(char[] name, ClusterContent content) [final] ¶#

ClusterContent get(char[] name) [final] ¶#

void copy(QueueFile[] dst, QueueFile[] src) [private, synchronized, final] ¶#

Workaround for a compiler bug in 0.018

void watchdog() [final] ¶#