Searched refs:getCurrentState (Results 1 – 1 of 1) sorted by relevance
173 Log.error("state was: " + getCurrentState()); in run()199 private synchronized State getCurrentState() { in getCurrentState() method in StreamConsumer