topicProducer.send(m1);
for (int i = 0; i < count; i++) { Message m = producerSession.createMessage(); queueProducer.send(m); }
         public void run()         {            try            {               // this is needed to make sure the main thread has enough time to block               Thread.sleep(1000);               topicProducer.send(m1);            }            catch(Exception e)            {               log.error(e);            }         }