Initial POC implementation
Initial message streaming setup
Fix exchange operation; add roles able to read messages; add streaming view