4719 Common patchset for jdk1.7 support preparation

@@ -607,11 +607,11 @@
             beforeGo(consumer);
             System.out.println("before go, running: " + consumer.isRunning());
             consumer.go();
             // Avoid race, call afterGo() in ConsumerListener
             try {
-                Thread.currentThread().sleep(300);
+                Thread.sleep(300);
             } catch (InterruptedException e) {
                 e.printStackTrace();
                 exit(1);
             }
             consumer.stop();