Searched refs:setErrorState (Results 1 – 1 of 1) sorted by relevance
135 setErrorState(); in consume()142 setErrorState(); in consume()145 setErrorState(); in consume()160 setErrorState(); in run()174 setErrorState(); in run()195 private synchronized void setErrorState() { in setErrorState() method in StreamConsumer