add shutdown
 * producer/consumer integration tests