+ private void addBAListener(Class<? extends Notification> notificationType,
+ NotificationListener listener) {
+
+ BrokerUtils.addToMap(listeners, notificationType, listener);
+ Mapper<? extends Notification> mapper = mappingProvider
+ .getMapper(notificationType);
+ QName biType = mapper.getQName();
+ if (false == biNotifications.contains(biType)) {
+ // The listener is not registered for binding independent
+ // notification
+ biNotifications.add(biType);
+
+ if (biNotifyService != null) {
+ biNotifyService.addNotificationListener(biType, biListener);
+ }
+ }
+
+ }
+
+ private void removeBAListener(
+ Class<? extends Notification> notificationType,
+ NotificationListener listener) {
+ BrokerUtils.removeFromMap(listeners, notificationType, listener);
+ }
+