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(JDCConnection oConnection, AtomQueue oAtomQueue)
Create Atom Queue Consumer

Method Summary

void	close()
JDCConnection	getConnection()
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(JDCConnection oConnection,
                    AtomQueue oAtomQueue)
             throws java.sql.SQLException

Create Atom Queue Consumer

Parameters:

oConnection -

oAtomQueue -

Throws:

java.sql.SQLException

Method Detail

close

public void close()

next

public Atom next()
          throws java.sql.SQLException

Get next Atom and remove it from queue

Returns:

Atom object instance

Throws:

java.sql.SQLException

getConnection

public JDCConnection getConnection()