Ajout de la logique pour le StreamProcessor
Corrections de merge