dbo.QBM_PJobQueueInit

1   create   procedure QBM_PJobQueueInit (@queue nvarchar(255) , @SessionID varchar(38) = ''  , @MaxWaitTimeForLock_s int = 40  ) as begin declare
2 @TestBetrieb bit = 0 declare @RCAppLockRequest int = 0 declare @MyName nvarchar(64) = object_name(@@procid) declare @WartenEinVersuch_ms int = 1000 declare
3 @WartenBisWiederholung_s int = 1 declare @Gestartet datetime = getutcdate() declare @HabeInitialisiert int = 1 SET XACT_ABORT OFF begin transaction BEGIN
4 TRY WirVersuchen: if datediff(ss, @Gestartet, getutcdate()) > @MaxWaitTimeForLock_s begin select @HabeInitialisiert = -1 exec QBM_PJobQueueInit_i @Queue
5, @SessionID, @SetSessionOnly = 1 goto endlabel end if not exists (select top 1 1 from JobQueue q with (readpast) where q.Ready2EXE in (N'LOADED', N'PROCESSING'
6, N'MISSING', 'FINISHED') and q.Queue = @queue ) and @TestBetrieb = 0 begin   exec QBM_PJobQueueInit_i @Queue, @SessionID, @SetSessionOnly = 1 goto endLabel
7 end exec @RCAppLockRequest = sys.sp_getapplock @Resource = @MyName , @LockMode='Exclusive' , @LockOwner='Transaction' , @LockTimeout = @WartenEinVersuch_ms
8 if @RCAppLockRequest < 0 begin   exec QBM_PWaitForSeconds @WartenBisWiederholung_s  goto wirVersuchen end   exec QBM_PJobQueueInit_i @Queue, @SessionID
9, @SetSessionOnly = 0  END TRY BEGIN CATCH select @HabeInitialisiert = -1 exec QBM_PSessionErrorAdd default declare @Rethrow varchar(1000) = dbo.QBM_FGISessionErrorRethrow
10() RAISERROR (@Rethrow, 18, 1) WITH NOWAIT  END CATCH EndeMitRelease: exec sp_releaseapplock @Resource = @MyName , @LockOwner = 'Transaction' EndLabel:
11 if @@TRANCOUNT > 0 begin commit transaction  end  return (@HabeInitialisiert) end 
12