code: private void startConsumerThread() {
          Thread thread = new Thread(new Runnable() {
              @Override
              public void run() {
                  while (Boolean.TRUE) {
                      processQueue();
                  }
              }
          }, "ESMetricsConsumer"); //$NON-NLS-1$
          thread.setDaemon(true);
          thread.start();        
      }
docs: Starts a thread which will serially pull information off the blocking
  queue and submit that information to hawkular metrics.