private boolean pollStatsBrokerTopic(Destination topic){
  statsMessageListener.setDestination(topic);
  LOGGER.info("Setting the destination to " + getQueueName(topic));
  jmsTemplate.execute(STATS_BROKER_DESTINATION + getTopicName(topic),new ProducerCallbackImpl(statsQueue));
  try {
    Thread.sleep(1 * 500);
  }
 catch (  InterruptedException e) {
    e.printStackTrace();
  }
  return statsMessageListener.getStats() != null;
}

private boolean pollStatsBrokerTopic ( Destination topic ) { statsMessageListener . setDestination ( topic ) ; LOGGER . info ( "Setting the destination to " + getQueueName ( topic ) ) ; jmsTemplate . execute ( STATS_BROKER_DESTINATION + getTopicName ( topic ) , new ProducerCallbackImpl ( statsQueue ) ) ; try { Thread . sleep ( 1 * 500 ) ; } catch ( InterruptedException e ) { e . printStackTrace ( ) ; } return statsMessageListener . getStats ( ) != null ; }
poll the topic for statistics
