复制代码 代码如下:

USE TestDB

declare @conversation uniqueidentifier

while exists (select 1 from sys.transmission_queue )

begin

set @conversation = (select top 1 conversation_handle from sys.transmission_queue )

end conversation @conversation with cleanup

end

那么客户端接受到的消息如果没有处理，也会积攒在客户端队列中，其实就相当于许多未读邮件，我们可以使用以下脚本读取队列 ，读取后队列自动清空:

复制代码 代码如下:

USE TestDB

DECLARE @RecvReplyMsg NVARCHAR(100) ;

DECLARE @RecvReplyDlgHandle UNIQUEIDENTIFIER ;

BEGIN TRANSACTION ;

WHILE ( 1 = 1 )

BEGIN

WAITFOR

( RECEIVE TOP(1)

@RecvReplyDlgHandle = conversation_handle,

@RecvReplyMsg = message_body

FROM dbo.Test_TargetQueue

), TIMEOUT 1000 ;

END CONVERSATION @RecvReplyDlgHandle ;

SELECT @RecvReplyMsg AS ReceivedReplyMsg ;

END

COMMIT TRANSACTION ;