What design patterns would you use to implement a real-time data streaming pipeline handling high-throughput sensor telemetry for Raytheon systems?