Pipe processors together using the Connector object. More...

Classes
class	SlowQueueSource
	A queue source object that waits 5 seconds before outputting each event.

Static Public Member Functions
static void	main (String[] args)

Detailed Description

Pipe processors together using the Connector object.

The chain of processors in this example is almost identical to PipingBinary, and can be represented graphically as:

The difference is that the first queue source has been replaced by a "slow" queue source, that waits 5 seconds before outputting an event.

Definition at line 42 of file PipingBinaryWait.java.

The documentation for this class was generated from the following file:

Classes