Closed
Description
New OIH Action: Re-Assemble after Stream End
Non-standard Action
- This is similar to the existing re-assemble option however, this is for the case where the group size is not known in advance.
- This is probably most similar to the Create CSV From Message Stream action in the CSV component minus the converting to CSV part
- Use case is you want to wait for the work in the steps previous to finish and then continue
- I'm not sure if this makes sense in splitter or some other component (e.g. utility)
Config Fields
- Waiting Interval (number, optional): Amount of time to wait in between messages to consider the result closed. (Given that the platform will put to sleep any containers which have empty queues for more than 30 seconds, this value can not be more than 30 seconds.
Input Metadata
- Message Id (string, optional: default to a random GUID): Key to record this message in the output.
- Message Data (object, optional: default to undefined}): Value to pass to future steps.
Output Metadata
The message emitted from the re-assemble action has a property messageData which is an object. For each message in the group, there is a property in this data object where the key for this object is the messageId and the value is the corresponding messageData
Implementation Notes
- There is no need to handle multiple Group IDs in the first iteration