topicProducer.send(topic2, m1);
anonProducer.send(topic2, m1);
         public void run()         {            try            {               // this is needed to make sure the main thread has enough time to block               Thread.sleep(1000);               topicProducer.send(topic2, m1);            }            catch(Exception e)            {               log.error(e);            }         }