subscription.unsubscribe();  wsnBroker.notify("myTopic", new Notify());  Thread.sleep(50);  assertEquals(0, pullPoint.getMessages(0).size());
wsnBroker.notify("myTopic", new Notify());  Thread.sleep(50);
	public void testUnsubscribe() throws Exception {        // START SNIPPET: sub		PullPoint pullPoint = wsnCreatePullPoint.createPullPoint();		Subscription subscription = wsnBroker.subscribe(pullPoint.getEndpoint(), "myTopic", null);        // END SNIPPET: sub				wsnBroker.notify("myTopic", new Notify());		// Wait for notification		Thread.sleep(50);				assertEquals(1, pullPoint.getMessages(0).size());		subscription.unsubscribe();				wsnBroker.notify("myTopic", new Notify());		// Wait for notification		Thread.sleep(50);				assertEquals(0, pullPoint.getMessages(0).size());		// Wait for acks to be processed		Thread.sleep(50);	}