服务经纪人与激活程序错误

Question

我创建了一个目标队列使用服务代理。我的目标队列在SQL Server收到的消息是这样的：

USE [DatabaseB] 
GO 

ALTER QUEUE [dbo].[TargetQueue] WITH STATUS = OFF , RETENTION = OFF , ACTIVATION ( STATUS = ON , PROCEDURE_NAME = [dbo].[myp] , MAX_QUEUE_READERS = 10 , EXECUTE AS N'dbo' ), POISON_MESSAGE_HANDLING (STATUS = ON) 

这里是我的存储过程，我打电话的时候，该消息在target_queue

ALTER PROCEDURE [DBO]接收。[MYP]

AS 


WHILE (1=1) 
    BEGIN 

    Declare @ConversationHandle as uniqueidentifier 
Declare @MessageBody as nvarchar(max) 
Declare @MessageType as sysname 

Begin Transaction 
Print 'Started Receiving '; 

RECEIVE top (1) 
     @MessageType = message_type_name, 
     @ConversationHandle = conversation_handle, 
    @MessageBody = message_body 
FROM TargetQueue; 

if @MessageType = 'SenderMessageType' 
     Begin 
      SEND 
        ON CONVERSATION @ConversationHandle 
        Message Type ReceiverMessageType 
        ('Message is received') 
      END Conversation @ConversationHandle 
      insert into table_1 (dataa) values ('salam') 
     END 

Commit 


    end 

但是，当由队列接收到的消息我的商店过程增添了无限数据到table_1但我有一个条件，你可以看到上面，我的意思是收到的每个消息sp应该添加一行表，而不是无限的行。为什么？

Answer 1

我只是改变了存储过程这样：

ALTER PROCEDURE [dbo].[myp] 

AS 


WHILE (1=1) 
    BEGIN 

    Declare @ConversationHandle as uniqueidentifier 
Declare @MessageBody as nvarchar(max) 
Declare @MessageType as sysname 

Begin Transaction 
Print 'Started Receiving '; 
WAITFOR 
    (
RECEIVE top (1) 
     @MessageType = message_type_name, 
     @ConversationHandle = conversation_handle, 
    @MessageBody = message_body 
FROM TargetQueue), TIMEOUT 5000; 
IF (@@ROWCOUNT = 0) 
    BEGIN 
     ROLLBACK TRANSACTION; 
     BREAK; 
    END 

if @MessageType = 'SenderMessageType' 
     Begin 
      SEND 
        ON CONVERSATION @ConversationHandle 
        Message Type ReceiverMessageType 
        ('Message is received') 
      END Conversation @ConversationHandle 
      insert into table_12 (dataa) values ('salam') 
     END 

Commit 


    end