Emitter Runtime Environment

The runtime environment to execute emitter components simply listens to the attached message queue for new items. Each incoming message is handed over to the assigned emitter for further processing.

As waiting for new messages is required the environment is implemented as java.lang.Runnable and keeps on spinning until it is interrupted by the surrounding micro pipeline.

For more information, please see the source code.