EndpointReferenceType consumer = createEPR(ReceiverComponent.SERVICE, ReceiverComponent.ENDPOINT); wsnBroker.subscribe(consumer, "myTopic", null, true);  Element body = parse("<hello>world</hello>");
Element body = parse("<hello>world</hello>");
	public void testRawNotify() throws Exception {		ReceiverComponent receiver = new ReceiverComponent();		jbi.activateComponent(receiver, "receiver");		// START SNIPPET: notify		EndpointReferenceType consumer = createEPR(ReceiverComponent.SERVICE, ReceiverComponent.ENDPOINT);		wsnBroker.subscribe(consumer, "myTopic", null, true);				Element body = parse("<hello>world</hello>");        wsnBroker.notify("myTopic", body);        // END SNIPPET: notify        		// Wait for notification		Thread.sleep(50);				receiver.getMessageList().assertMessagesReceived(1);		NormalizedMessage msg = (NormalizedMessage) receiver.getMessageList().getMessages().get(0);		Node node = new SourceTransformer().toDOMNode(msg);		assertEquals("hello", node.getLocalName());				// Wait for acks to be processed		Thread.sleep(50);	}