The StreamConsumer inner loop was not checking the consumer state.
The StreamConsumer inner loop was not checking the consumer state.
cometman/datasift_ruby_AWS_fix,datasift/datasift-ruby,cometman/datasift_ruby_AWS_fix