com.knowgate.scheduler
Class AtomConsumer

java.lang.Object
  com.knowgate.scheduler.AtomConsumer

public class AtomConsumer
extends java.lang.Object

Atom queue consumer

Constructor Summary

AtomConsumer(DBBind oDbBnd, AtomQueue oAtomQueue)
Create Atom Queue Consumer

Method Summary

void	close()
DBBind	getDatabaseBind()
Atom	next() Get next Atom and remove it from queue

Methods inherited from class java.lang.Object

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

Constructor Detail

AtomConsumer

public AtomConsumer(DBBind oDbBnd,
                    AtomQueue oAtomQueue)
             throws java.sql.SQLException

Create Atom Queue Consumer

Parameters:

oConnection -

oAtomQueue -

Throws:

java.sql.SQLException

Method Detail

getDatabaseBind

public DBBind getDatabaseBind()

close

public void close()
           throws java.sql.SQLException

Throws:

java.sql.SQLException

next

public Atom next()
          throws java.sql.SQLException

Get next Atom and remove it from queue

Returns:

Atom object instance

Throws:

java.sql.SQLException