--- StompTest.java.orig 2007-08-21 08:47:14.468750000 +0800 +++ StompTest.java 2007-08-21 08:40:58.890625000 +0800 @@ -39,7 +39,6 @@ import org.apache.activemq.broker.TransportConnector; import org.apache.activemq.command.ActiveMQQueue; import org.apache.activemq.command.ActiveMQTextMessage; -import org.apache.activemq.transport.reliable.UnreliableUdpTransportTest; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; @@ -126,6 +125,24 @@ } + public void testStompExpireProperty() throws Exception { + + String frame = "CONNECT\n" + "login: brianm\n" + "passcode: wombats\n\n" + Stomp.NULL; + stompConnection.sendFrame(frame); + + frame = stompConnection.receiveFrame(); + assertTrue(frame.startsWith("CONNECTED")); + + frame = "SUBSCRIBE\n" + "destination:/queue/" + getQueueName() + "\n" + "ack:auto\n\n" + Stomp.NULL; + stompConnection.sendFrame(frame); + long expires = 10; + frame = "SEND\n" + "destination:/queue/" + getQueueName() +"\n"+"expires:"+expires+"\n\n" + "Hello World" + Stomp.NULL; + stompConnection.sendFrame(frame); + frame = stompConnection.receiveFrame(); + assertTrue(frame.startsWith("MESSAGE")); + + } + public void testSendMessage() throws Exception { MessageConsumer consumer = session.createConsumer(queue);