com.grey.naf.reactor

Class Producer<T>

java.lang.Object

com.grey.naf.reactor.Producer<T>

public class Producer<T>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	Producer.Consumer<T>

Field Summary

Fields

Modifier and Type	Field and Description
String	consumerType

Constructor Summary

Constructors

Constructor and Description
Producer(Class<T> clss, Dispatcher dsptch, Producer.Consumer<T> cons)
Producer(Class<T> clss, Producer.Consumer<T> cons, Logger log)

Method Summary

Modifier and Type	Method and Description
T	consume()
Dispatcher	getDispatcher()
void	produce(ArrayList<T> items)
void	produce(T item)
void	produce(T[] items)
void	produce(T[] items, int off, int len)
void	shutdown()
void	shutdown(boolean consume_pending)

Methods inherited from class java.lang.Object

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

Field Detail

consumerType

public final String consumerType

Constructor Detail

Producer

public Producer(Class<T> clss,
                Dispatcher dsptch,
                Producer.Consumer<T> cons)
         throws IOException

Throws:

IOException

Producer

public Producer(Class<T> clss,
                Producer.Consumer<T> cons,
                Logger log)
         throws IOException

Throws:

IOException

Method Detail

getDispatcher

public Dispatcher getDispatcher()

shutdown

public void shutdown()

shutdown

public void shutdown(boolean consume_pending)

consume

public T consume()

produce

public void produce(T item)
             throws IOException

Throws:

IOException

produce

public void produce(ArrayList<T> items)
             throws IOException

Throws:

IOException

produce

public void produce(T[] items,
                    int off,
                    int len)
             throws IOException

Throws:

IOException

produce

public void produce(T[] items)
             throws IOException

Throws:

IOException