import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-public class HeliumNotificationProviderServiceAdapter extends HeliumNotificationServiceAdapter implements NotificationProviderService, AutoCloseable {
+public class HeliumNotificationProviderServiceAdapter extends HeliumNotificationServiceAdapter
+ implements NotificationProviderService {
private static final Logger LOG = LoggerFactory.getLogger(HeliumNotificationProviderServiceAdapter.class);
private final NotificationPublishService notificationPublishService;
- public HeliumNotificationProviderServiceAdapter(NotificationPublishService notificationPublishService,
- NotificationService notificationService) {
+ public HeliumNotificationProviderServiceAdapter(final NotificationPublishService notificationPublishService,
+ final NotificationService notificationService) {
super(notificationService);
this.notificationPublishService = notificationPublishService;
}
try {
notificationPublishService.putNotification(notification);
} catch (InterruptedException e) {
- LOG.error("Notification publication was interupted: " + e);
+ LOG.error("Notification publication was interupted", e);
}
}
try {
notificationPublishService.putNotification(notification);
} catch (InterruptedException e) {
- LOG.error("Notification publication was interupted: " + e);
+ LOG.error("Notification publication was interupted", e);
}
}
@Override
public ListenerRegistration<NotificationInterestListener> registerInterestListener(
- NotificationInterestListener interestListener) {
+ final NotificationInterestListener interestListener) {
throw new UnsupportedOperationException("InterestListener is not supported.");
}
@Override
- public void close() throws Exception {
+ public void close() {
}
-
}