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