aboutsummaryrefslogtreecommitdiffstats
path: root/sonar-server/src/main/java/org/sonar/server/notifications/NotificationService.java
diff options
context:
space:
mode:
Diffstat (limited to 'sonar-server/src/main/java/org/sonar/server/notifications/NotificationService.java')
-rw-r--r--sonar-server/src/main/java/org/sonar/server/notifications/NotificationService.java9
1 files changed, 4 insertions, 5 deletions
diff --git a/sonar-server/src/main/java/org/sonar/server/notifications/NotificationService.java b/sonar-server/src/main/java/org/sonar/server/notifications/NotificationService.java
index 29d1690e1e7..c2b6dbf4ab8 100644
--- a/sonar-server/src/main/java/org/sonar/server/notifications/NotificationService.java
+++ b/sonar-server/src/main/java/org/sonar/server/notifications/NotificationService.java
@@ -33,7 +33,6 @@ import org.sonar.api.notifications.NotificationChannel;
import org.sonar.api.notifications.NotificationDispatcher;
import org.sonar.api.utils.TimeProfiler;
import org.sonar.core.notification.DefaultNotificationManager;
-import org.sonar.core.notification.NotificationQueueElement;
import java.util.Arrays;
import java.util.Collection;
@@ -115,13 +114,13 @@ public class NotificationService implements ServerComponent {
synchronized void processQueue() {
TIME_PROFILER.start("Processing notifications queue");
- NotificationQueueElement queueElement = manager.getFromQueue();
- while (queueElement != null) {
- deliver(queueElement.getNotification());
+ Notification notifToSend = manager.getFromQueue();
+ while (notifToSend != null) {
+ deliver(notifToSend);
if (stopping) {
break;
}
- queueElement = manager.getFromQueue();
+ notifToSend = manager.getFromQueue();
}
TIME_PROFILER.stop();