queueProducer = producerSession.createProducer(queue); queueConsumer = consumerSession.createConsumer(queue);
   public void setUp() throws Exception   {      super.setUp();      ServerManagement.startInVMServer();      ServerManagement.deployTopic("Topic");      ServerManagement.deployQueue("Queue");      InitialContext ic = new InitialContext(InVMInitialContextFactory.getJNDIEnvironment());      ConnectionFactory cf = (ConnectionFactory)ic.lookup("/messaging/ConnectionFactory");      Destination topic = (Destination)ic.lookup("/messaging/topics/Topic");      Destination queue = (Destination)ic.lookup("/messaging/queues/Queue");      producerConnection = cf.createConnection();      consumerConnection = cf.createConnection();      producerSession = producerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);      consumerSession = consumerConnection.createSession(false, Session.AUTO_ACKNOWLEDGE);      topicProducer = producerSession.createProducer(topic);      topicConsumer = consumerSession.createConsumer(topic);//      queueProducer = producerSession.createProducer(queue);//      queueConsumer = consumerSession.createConsumer(queue);   }