NotificationMessageHolderType message = callback.notifications.get(0);
assertEquals(WSNHelper.getInstance().getWSAAddress(subscription.getEpr()),
WSNHelper.getInstance().getWSAAddress(message.getSubscriptionReference()));
subscription.unsubscribe();
consumer.stop();
}
@Test
public void testPullPoint() throws Exception {
PullPoint pullPoint = createPullPoint.create();