USE master
GO
ALTER DATABASE Util SET SINGLE_USER WITH ROLLBACK IMMEDIATE
GO
ALTER DATABASE Util SET DISABLE_BROKER WITH ROLLBACK IMMEDIATE
GO
ALTER DATABASE Util SET MULTI_USER
GO
USE master
GO
ALTER DATABASE Util SET SINGLE_USER WITH ROLLBACK IMMEDIATE
GO
ALTER DATABASE Util SET ENABLE_BROKER WITH ROLLBACK IMMEDIATE
GO
ALTER DATABASE Util SET MULTI_USER
GO
USE Util
GO
--#region DROP ALL
SET NOCOUNT ON
DECLARE @SQL VARCHAR(MAX),
@PrintSQL BIT = 1,
@ExecSQL BIT = 1
SELECT @SQL = Util.dbo.StringConcat(SQL, '
')
FROM (SELECT 'DROP SERVICE [' + name + '];' AS SQL
FROM sys.services
WHERE NAME LIKE '//Util/%'
UNION ALL
SELECT 'DROP QUEUE ' + name + ';'
FROM sys.service_queues
WHERE name LIKE 'SQL[IE]%'
UNION ALL
SELECT 'DROP ROUTE ' + name + ';'
FROM sys.routes
WHERE remote_service_name LIKE '//Util/%'
UNION ALL
SELECT 'DROP CONTRACT [' + name + '];'
FROM sys.service_contracts
WHERE NAME LIKE '//Util/%'
UNION ALL
SELECT 'DROP MESSAGE TYPE [' + NAME + '];'
FROM sys.service_message_types
WHERE NAME LIKE '//Util/%') k
IF @PrintSQL = 1
EXEC Util.dbo.PrintLargeText
@SQL
IF @ExecSQL = 1
EXEC(@SQL)
GO
--#endregion
GO
CREATE MESSAGE TYPE [//Util/SQLExecution/RequestMessage] VALIDATION = WELL_FORMED_XML ;
GO
CREATE CONTRACT [//Util/SQLExecution/DContract] ([//Util/SQLExecution/RequestMessage] SENT BY INITIATOR) ;
--, [//Util/SQLExecution/ReplyMessage] SENT BY TARGET ) ;
GO
-- CREATE MESSAGE TYPE [//Util/SQLExecution/ReplyMessage] VALIDATION = WELL_FORMED_XML;
GO
--------- CREATE ---------
--#region CREATE QUE, SERVICES, ROUTES
GO
CREATE QUEUE SQLExecutionQueue_1 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_1] ON QUEUE SQLExecutionQueue_1 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_1 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_1', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_2 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_2] ON QUEUE SQLExecutionQueue_2 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_2 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_2', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_3 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_3] ON QUEUE SQLExecutionQueue_3 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_3 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_3', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_4 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_4] ON QUEUE SQLExecutionQueue_4 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_4 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_4', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_5 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_5] ON QUEUE SQLExecutionQueue_5 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_5 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_5', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_6 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_6] ON QUEUE SQLExecutionQueue_6 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_6 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_6', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_7 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_7] ON QUEUE SQLExecutionQueue_7 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_7 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_7', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_8 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_8] ON QUEUE SQLExecutionQueue_8 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_8 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_8', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_9 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_9] ON QUEUE SQLExecutionQueue_9 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_9 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_9', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_10 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_10] ON QUEUE SQLExecutionQueue_10 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_10 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_10', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_11 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_11] ON QUEUE SQLExecutionQueue_11 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_11 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_11', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_12 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_12] ON QUEUE SQLExecutionQueue_12 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_12 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_12', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_13 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_13] ON QUEUE SQLExecutionQueue_13 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_13 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_13', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_14 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_14] ON QUEUE SQLExecutionQueue_14 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_14 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_14', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_15 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_15] ON QUEUE SQLExecutionQueue_15 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_15 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_15', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_16 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_16] ON QUEUE SQLExecutionQueue_16 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_16 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_16', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_17 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_17] ON QUEUE SQLExecutionQueue_17 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_17 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_17', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_18 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_18] ON QUEUE SQLExecutionQueue_18 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_18 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_18', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_19 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_19] ON QUEUE SQLExecutionQueue_19 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_19 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_19', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_20 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_20] ON QUEUE SQLExecutionQueue_20 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_20 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_20', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_21 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_21] ON QUEUE SQLExecutionQueue_21 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_21 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_21', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_22 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_22] ON QUEUE SQLExecutionQueue_22 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_22 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_22', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_23 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_23] ON QUEUE SQLExecutionQueue_23 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_23 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_23', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_24 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_24] ON QUEUE SQLExecutionQueue_24 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_24 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_24', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_25 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_25] ON QUEUE SQLExecutionQueue_25 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_25 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_25', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_26 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_26] ON QUEUE SQLExecutionQueue_26 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_26 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_26', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_27 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_27] ON QUEUE SQLExecutionQueue_27 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_27 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_27', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_28 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_28] ON QUEUE SQLExecutionQueue_28 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_28 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_28', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_29 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_29] ON QUEUE SQLExecutionQueue_29 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_29 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_29', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_30 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_30] ON QUEUE SQLExecutionQueue_30 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_30 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_30', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_31 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_31] ON QUEUE SQLExecutionQueue_31 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_31 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_31', ADDRESS = 'LOCAL' ;
GO
CREATE QUEUE SQLExecutionQueue_32 ;
GO
CREATE SERVICE [//Util/SQLExecution/TargetService_32] ON QUEUE SQLExecutionQueue_32 ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionTargetRoute_32 WITH SERVICE_NAME = '//Util/SQLExecution/TargetService_32', ADDRESS = 'LOCAL' ;
GO
--#endregion
GO
CREATE QUEUE SQLInitiatorQueue
GO
CREATE SERVICE [//Util/SQLExecution/InitiatorService] ON QUEUE SQLInitiatorQueue ([//Util/SQLExecution/DContract]) ;
GO
CREATE ROUTE SQLExecutionInitiatorRoute WITH SERVICE_NAME = '//Util/SQLExecution/InitiatorService', ADDRESS = 'LOCAL' ;
GO
--#region trg_SQLExecution_Insert
DROP TRIGGER [SE].trg_SQLExecution_Insert
GO
CREATE TRIGGER trg_SQLExecution_Insert ON [SE].[SQLExecution]
FOR INSERT
AS
SET NOCOUNT ON
DECLARE @RequestMsg XML
--#region Initialize Handles
DECLARE @InitDlgHandle_1 UNIQUEIDENTIFIER,
@InitDlgHandle_2 UNIQUEIDENTIFIER,
@InitDlgHandle_3 UNIQUEIDENTIFIER,
@InitDlgHandle_4 UNIQUEIDENTIFIER,
@InitDlgHandle_5 UNIQUEIDENTIFIER,
@InitDlgHandle_6 UNIQUEIDENTIFIER,
@InitDlgHandle_7 UNIQUEIDENTIFIER,
@InitDlgHandle_8 UNIQUEIDENTIFIER,
@InitDlgHandle_9 UNIQUEIDENTIFIER,
@InitDlgHandle_10 UNIQUEIDENTIFIER,
@InitDlgHandle_11 UNIQUEIDENTIFIER,
@InitDlgHandle_12 UNIQUEIDENTIFIER,
@InitDlgHandle_13 UNIQUEIDENTIFIER,
@InitDlgHandle_14 UNIQUEIDENTIFIER,
@InitDlgHandle_15 UNIQUEIDENTIFIER,
@InitDlgHandle_16 UNIQUEIDENTIFIER,
@InitDlgHandle_17 UNIQUEIDENTIFIER,
@InitDlgHandle_18 UNIQUEIDENTIFIER,
@InitDlgHandle_19 UNIQUEIDENTIFIER,
@InitDlgHandle_20 UNIQUEIDENTIFIER,
@InitDlgHandle_21 UNIQUEIDENTIFIER,
@InitDlgHandle_22 UNIQUEIDENTIFIER,
@InitDlgHandle_23 UNIQUEIDENTIFIER,
@InitDlgHandle_24 UNIQUEIDENTIFIER,
@InitDlgHandle_25 UNIQUEIDENTIFIER,
@InitDlgHandle_26 UNIQUEIDENTIFIER,
@InitDlgHandle_27 UNIQUEIDENTIFIER,
@InitDlgHandle_28 UNIQUEIDENTIFIER,
@InitDlgHandle_29 UNIQUEIDENTIFIER,
@InitDlgHandle_30 UNIQUEIDENTIFIER,
@InitDlgHandle_31 UNIQUEIDENTIFIER,
@InitDlgHandle_32 UNIQUEIDENTIFIER
-- BEGIN TRANSACTION
BEGIN DIALOG @InitDlgHandle_1
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_1'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_2
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_2'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_3
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_3'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_4
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_4'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_5
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_5'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_6
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_6'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_7
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_7'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_8
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_8'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_9
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_9'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_10
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_10'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_11
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_11'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_12
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_12'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_13
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_13'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_14
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_14'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_15
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_15'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_16
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_16'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_17
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_17'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_18
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_18'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_19
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_19'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_20
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_20'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_21
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_21'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_22
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_22'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_23
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_23'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_24
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_24'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_25
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_25'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_26
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_26'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_27
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_27'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_28
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_28'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_29
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_29'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_30
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_30'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_31
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_31'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
BEGIN DIALOG @InitDlgHandle_32
FROM SERVICE [//Util/SQLExecution/InitiatorService]
TO SERVICE N'//Util/SQLExecution/TargetService_32'
ON CONTRACT [//Util/SQLExecution/DContract]
WITH
ENCRYPTION = OFF ;
--#endregion
DECLARE XMLCursor CURSOR FORWARD_ONLY
FOR
SELECT ExecutionXML = (SELECT ExecutionId
FOR XML RAW('RequestMsg'))
FROM INSERTED
OPEN XMLCursor
FETCH NEXT FROM XMLCursor INTO @RequestMsg
WHILE @@FETCH_STATUS = 0
BEGIN
--#region Send messages
SEND ON CONVERSATION @InitDlgHandle_1
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_2
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_3
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_4
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_5
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_6
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_7
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_8
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_9
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_10
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_11
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_12
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_13
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_14
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_15
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_16
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_17
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_18
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_19
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_20
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_21
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_22
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_23
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_24
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_25
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_26
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_27
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_28
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_29
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_30
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_31
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
SEND ON CONVERSATION @InitDlgHandle_32
MESSAGE TYPE
[//Util/SQLExecution/RequestMessage]
(@RequestMsg) ;
--#endregion
FETCH NEXT FROM XMLCursor INTO @RequestMsg
END
CLOSE XMLCursor
DEALLOCATE XMLCursor
--COMMIT TRANSACTION
GO
--#endregion
GO
--------- Stored Procedures ---------
--------- Stored Procedures ---------
--#region Activation Procedures
DROP PROCEDURE SE.SQLExecutionActivationProc_1
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_1
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_1
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_1'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_2
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_2
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_2
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_2'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_3
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_3
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_3
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_3'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_4
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_4
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_4
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_4'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_5
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_5
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_5
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_5'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_6
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_6
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_6
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_6'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_7
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_7
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_7
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_7'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_8
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_8
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_8
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_8'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_9
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_9
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_9
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_9'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_10
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_10
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_10
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_10'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_11
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_11
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_11
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_11'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_12
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_12
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_12
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_12'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_13
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_13
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_13
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_13'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_14
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_14
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_14
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_14'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_15
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_15
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_15
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_15'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_16
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_16
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_16
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_16'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_17
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_17
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_17
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_17'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_18
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_18
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_18
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_18'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_19
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_19
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_19
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_19'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_20
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_20
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_20
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_20'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_21
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_21
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_21
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_21'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_22
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_22
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_22
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_22'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_23
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_23
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_23
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_23'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_24
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_24
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_24
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_24'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_25
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_25
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_25
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_25'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_26
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_26
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_26
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_26'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_27
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_27
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_27
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_27'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_28
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_28
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_28
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_28'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_29
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_29
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_29
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_29'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_30
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_30
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_30
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_30'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_31
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_31
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_31
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_31'
END
GO
DROP PROCEDURE SE.SQLExecutionActivationProc_32
GO
CREATE PROCEDURE SE.SQLExecutionActivationProc_32
-- WITH EXECUTE AS CALLER
AS
DECLARE @RecvReqDlgHandle UNIQUEIDENTIFIER,
@RecvReqMsg XML,
@RecvReqMsgName SYSNAME,
@ExecutionId INT
WHILE (1 = 1)
BEGIN
SET @ExecutionId = NULL
WAITFOR
( RECEIVE TOP(1)
@RecvReqDlgHandle = conversation_handle,
@RecvReqMsg = message_body,
@RecvReqMsgName = message_type_name
FROM SQLExecutionQueue_32
)--, TIMEOUT 100;
IF (@@ROWCOUNT = 0)
BREAK;
IF @RecvReqMsgName = N'//Util/SQLExecution/RequestMessage'
SELECT @ExecutionId = T.item.value('@ExecutionId', 'int')
FROM @RecvReqMsg.nodes('/RequestMsg') AS T (item)
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/EndDialog'
END CONVERSATION @RecvReqDlgHandle;
ELSE
IF @RecvReqMsgName = N'http://schemas.microsoft.com/SQL/ServiceBroker/Error'
END CONVERSATION @RecvReqDlgHandle;
IF @ExecutionId > 0
EXEC SE.SQLExecutionExecProc @ExecutionId = @ExecutionId, @QueName = 'SQLExecutionQueue_32'
END
GO
--#endregion
--------- ALTER QUE ---------
--#region ALTER QUE
ALTER QUEUE SQLExecutionQueue_1
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_1,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_2
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_2,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_3
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_3,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_4
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_4,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_5
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_5,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_6
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_6,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_7
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_7,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_8
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_8,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_9
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_9,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_10
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_10,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_11
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_11,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_12
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_12,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_13
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_13,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_14
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_14,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_15
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_15,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_16
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_16,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_17
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_17,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_18
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_18,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_19
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_19,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_20
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_20,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_21
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_21,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_22
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_22,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_23
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_23,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_24
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_24,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_25
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_25,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_26
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_26,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_27
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_27,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_28
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_28,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_29
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_29,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_30
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_30,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_31
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_31,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
ALTER QUEUE SQLExecutionQueue_32
WITH ACTIVATION
( STATUS = ON,
PROCEDURE_NAME = SE.SQLExecutionActivationProc_32,
MAX_QUEUE_READERS = 2
,EXECUTE AS SELF
--,EXECUTE AS CALLER
);
GO
--#endregion