Adds a publish/subscribe example

This example shows how to reliably publish and consume from different
connections so that the broker can pushback on the publisher by closing
the congestion window, while the subscribers can still consume to
release broker memory.