The Siddhi query uses the
custom:fault() extension generates the error detected bsed on the specified condition (i.e., if the volume is less than a specified amount). If no error is detected, the output is inserted into
StreamB stream. However, if an error is detected, it is logged with the
Error Occured text. The output is inserted into a stream named
tempStream, and the error details are presented via the
_error stream attribute (which is automatically included in the
!StreamA i fault stream and then inserted into the TempStream which is the inferred output stream).
Please note that custom:fault() extension is a custom extension written to simulate throwing runtime exceptions. This extension is not bundled within the product.
Handling errors that occur when publishing the output