Adding the bits need to do producer flow control with a window to the broker. Just implemented on the Queue case for now.