About processors

Processors form the core of the Joule platform. A processor performs a distinct unique function when chained with others form a business use case


Overview

A use case core definition is based upon the processing pipeline. A pipeline is formed of one or more linked processors. This follows the functional programming paradigm whereby each processor performs a distinct process.

Events are processed in sequence with the final event either being presented to a select processor or directly to connected transports.


Available processor types

Joule has provided a number of core processors for developers to leverage to build domain use case. Processors can be categorised in to various functional grouping that reflect there purpose within the platform.

Filtering

Reduce stream processing overhead by filtering unnecessary events

Enrichment

Enrich events using linked reference data, metrics and analytics

Transformation

Transform event attribute values based upon a desired target state

Analytics

Gain insights through stream based analytic functions

Triggers

Apply rule based triggers for downstream business actions


Observability and Metrics

Each OOTB processor record and presents event metrics to JMX monitoring platforms. This provides direct insight into how a streaming use case is performing.

Metrics available

  • Received

  • Processed

  • Failed

  • Discarded

  • Ignored

  • Average processing latency

All of these metrics are enabled by default and presented as JMX beans on the standard monitoring ports.

Enable JMX

Apply these settings to the joule execution path

-Dcom.sun.management.jmxremote.port=5000
-Dcom.sun.management.jmxremote.rmi.port=5000

For further information use the instructions in Monitoring and Management Using JMX Technology

Last updated