Make Stream Agent procs run in /tmp
Add stream manager
Add requirements.txt
Add schema
Add gitignore
Fix publish and consume functions
Tidy up tests and output handling