super.tearDown();
}
public void testSimplestDurableSubscription() throws Exception
{
ConnectionFactory cf = (ConnectionFactory)ic.lookup("ConnectionFactory");
Topic topic = (Topic)ic.lookup("/topic/Topic");
Connection conn = cf.createConnection();
conn.setClientID("brookeburke");
Session s = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageProducer prod = s.createProducer(topic);
prod.setDeliveryMode(DeliveryMode.PERSISTENT);
s.createDurableSubscriber(topic, "monicabelucci");
ObjectName destObjectName =
new ObjectName("jboss.messaging.destination:service=Topic,name=Topic");
List subs = (List)ServerManagement.invoke(destObjectName, "listAllSubscriptions", null, null);
assertNotNull(subs);
assertEquals(1, subs.size());
SubscriptionInfo info = (SubscriptionInfo)subs.get(0);
assertEquals("monicabelucci", info.getName());
prod.send(s.createTextMessage("k"));
conn.close();
subs = (List)ServerManagement.invoke(destObjectName, "listAllSubscriptions", null, null);
assertEquals(1, subs.size());
info = (SubscriptionInfo)subs.get(0);
assertEquals("monicabelucci", info.getName());
conn = cf.createConnection();
conn.setClientID("brookeburke");
s = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
MessageConsumer durable = s.createDurableSubscriber(topic, "monicabelucci");