@Test(timeout=30000) public void testSessionCreateProducer() throws Exception {
  connection=createAmqpConnection();
  assertNotNull(connection);
  Session session=connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
  assertNotNull(session);
  Queue queue=session.createQueue("test.queue");
  MessageProducer producer=session.createProducer(queue);
  producer.close();
  session.close();
}