org.xmlBlaster.engine.query.plugins
Class QueueQueryPlugin.WaitingQuery

java.lang.Object
  org.xmlBlaster.engine.query.plugins.QueueQueryPlugin.WaitingQuery

Enclosing class:

QueueQueryPlugin

class QueueQueryPlugin.WaitingQuery

extends java.lang.Object

Helper container

Field Summary

(package private) int	maxEntries The maximum number of entries for which to wait.
(package private) long	maxSize The maximum number of bytes which need to be in the queue before it will continue.
(package private) edu.emory.mathcs.backport.java.util.concurrent.CountDownLatch	startSignal

Constructor Summary

QueueQueryPlugin.WaitingQuery(int maxEntries, long maxSize)

Methods inherited from class java.lang.Object

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

Field Detail

maxEntries

int maxEntries

The maximum number of entries for which to wait. If negative no restriction is given, so the the other limitations count.

maxSize

long maxSize

The maximum number of bytes which need to be in the queue before it will continue. If negative no restriction is given.

startSignal

edu.emory.mathcs.backport.java.util.concurrent.CountDownLatch startSignal

Constructor Detail

QueueQueryPlugin.WaitingQuery

public QueueQueryPlugin.WaitingQuery(int maxEntries,
                                     long maxSize)