increase connection heartbeat timeout to 30 secs + simplify broker shutdown + move common code out of Consumer and Subscriber to BaseMessageReceiver