We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4c3ea39 commit 0877478Copy full SHA for 0877478
1 file changed
server/odc-service/src/main/java/com/oceanbase/odc/metadb/notification/MessageRepository.java
@@ -63,6 +63,8 @@ List<MessageEntity> findNByStatusForUpdate(@Param("status") MessageSendingStatus
63
@Query(value = "update notification_message set `status`='SENT_FAILED' where `status`='SENDING' and "
64
+ "`update_time` < DATE_SUB(now(), INTERVAL :timeoutSeconds SECOND)",
65
nativeQuery = true)
66
+ @Modifying
67
+ @Transactional
68
int failSendingTimeoutMessages(@Param("timeoutSeconds") long timeoutSeconds);
69
70
default Page<MessageEntity> find(@NonNull QueryMessageParams queryParams, @NonNull Pageable pageable) {
0 commit comments