Producer continues to `publish` and Consumer's `loop` is stuck silently on failure of network connection to broker. How should a client application be notified that the connection is broken? A connection exception?