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