o Automatic recursive processing of failed batches.
o Add a capability to inject filters for incoming data.
o Add optional pre-process methods.
