diff options
Diffstat (limited to 'src/main/java/org/onap/dcaegen2/services/sonhms/dao/PerformanceNotificationsRepository.java')
| -rw-r--r-- | src/main/java/org/onap/dcaegen2/services/sonhms/dao/PerformanceNotificationsRepository.java | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/src/main/java/org/onap/dcaegen2/services/sonhms/dao/PerformanceNotificationsRepository.java b/src/main/java/org/onap/dcaegen2/services/sonhms/dao/PerformanceNotificationsRepository.java index c83956f..d45d7de 100644 --- a/src/main/java/org/onap/dcaegen2/services/sonhms/dao/PerformanceNotificationsRepository.java +++ b/src/main/java/org/onap/dcaegen2/services/sonhms/dao/PerformanceNotificationsRepository.java @@ -28,11 +28,10 @@ import org.springframework.stereotype.Repository; @Repository public interface PerformanceNotificationsRepository extends CrudRepository<PerformanceNotifications, String> { - - @Query(nativeQuery = true, - value = "DELETE FROM performance_notifications " - + "WHERE notification = ( SELECT notification FROM performance_notifications ORDER BY " - + "created_at FOR UPDATE SKIP LOCKED LIMIT 1 ) RETURNING notification;") + + @Query(nativeQuery = true, value = "DELETE FROM performance_notifications " + + "WHERE notification = ( SELECT notification FROM performance_notifications ORDER BY " + + "created_at FOR UPDATE SKIP LOCKED LIMIT 1 ) RETURNING notification;") public String getPerformanceNotificationFromQueue(); |