Thread.sleep(50); }
wsnBroker.notify("myTopic", new Notify());  Thread.sleep(50);  List<NotificationMessageHolderType> msgs = pullPoint.getMessages(0); assertNotNull(msgs); assertEquals(1, msgs.size());   Thread.sleep(50); }
	public void testPull() throws Exception {		PullPoint pullPoint = wsnCreatePullPoint.createPullPoint();		wsnBroker.subscribe(pullPoint.getEndpoint(), "myTopic", null);				wsnBroker.notify("myTopic", new Notify());		// Wait for notification		Thread.sleep(50);				List<NotificationMessageHolderType> msgs = pullPoint.getMessages(0);		assertNotNull(msgs);		assertEquals(1, msgs.size());		// Wait for acks to be processed		Thread.sleep(50);	}