DRRealtimeCollector(4.3)
The realtime collector implements the DRRealtimeThreadAgent
class.
As previously described, the realtime collector may choose to implement the consume
method to handle request/response mechanisms. To tell the Workflow Editor that this capability exists, the Inspectable
for the collector must return the response UDR Type in the getInputTypes
method.
When you create an agent which can use a "lazy" method of decoding, if an error occurs during lazy decoding in the agent that includes APL code configuration, a DRUnwindException
is thrown. This exception must be caught to prevent the workflow from aborting.
To catch a DRUnwindException
 in the collector agent, you can use the function block provided below. Alternatively, you can catch this exception, by adding the try-catch
 function block to the APL code included in the workflow. For further information on try-catch
, see Function Blocks(3.0) in APL Reference Guide(3.0).
catch(final DRUnwindException e){ if(e.getAction() == DRUnwindException.CONTINUE) { logger.log(Level.WARNING, "An error message", e); } else { throw e; } }