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