4719 Common patchset for jdk1.7 support preparation

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