topicProducer.send(topic2, m1);
anonProducer.send(topic2, m1);
   public void testSendDestination() throws Exception   {      final Message m1 = producerSession.createMessage();      consumerConnection.start();      new Thread(new Runnable()      {         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);            }         }      }, "Producer").start();      Message m2 = topicConsumer2.receive(3000);      assertNotNull(m2);      assertEquals(m1.getJMSMessageID(), m2.getJMSMessageID());   }