Add low-level consumer/queue protocol.
Really small test-case
Add a very simple subscriber protocol and an initial scalatest.