Actually we should close producers before consumers. Otherwise, the producers continue to send Messages downstream after the consumers have been closed.