Added try/catch for generic Exception everywhere in collector_streaming for robustness