Author: clebert.suconic(a)jboss.com Date: 2009-10-01 18:37:37 -0400 (Thu, 01 Oct 2009) New Revision: 8029 Modified: trunk/tests/src/org/hornetq/tests/integration/jms/divert/DivertAndACKClientTest.java Log: small tweak Modified: trunk/tests/src/org/hornetq/tests/integration/jms/divert/DivertAndACKClientTest.java =================================================================== --- trunk/tests/src/org/hornetq/tests/integration/jms/divert/DivertAndACKClientTest.java 2009-10-01 22:18:38 UTC (rev 8028) +++ trunk/tests/src/org/hornetq/tests/integration/jms/divert/DivertAndACKClientTest.java 2009-10-01 22:37:37 UTC (rev 8029) @@ -90,6 +90,30 @@ connection.close(); } + public void testClientACK() throws Exception + { + HornetQQueue queueSource = (HornetQQueue)createQueue("Source"); + HornetQQueue queueTarget = (HornetQQueue)createQueue("Dest"); + + + Connection connection = cf.createConnection(); + Session session = connection.createSession(false, Session.CLIENT_ACKNOWLEDGE); + + final MessageProducer producer = session.createProducer(queueSource); + + final TextMessage message = session.createTextMessage("message text"); + producer.send(message); + + connection.start(); + + final MessageConsumer consumer = session.createConsumer(queueTarget); + TextMessage receivedMessage = (TextMessage)consumer.receive(1000); + assertNotNull(receivedMessage); + receivedMessage.acknowledge(); + + connection.close(); + } + // Package protected --------------------------------------------- // Protected -----------------------------------------------------