时间:2021-05-23
复制代码 代码如下:
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 ;
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
简介RocketMQ路由注册与删除是通过Broker与NameServer的心跳功能实现的。Broker启动时向集群中所有的NameServer发送心跳语句,每
下面是sqlserver数据库压缩sql语句的介绍 1.清空日志 DUMPTRANSACTION数据库名WITHNO_LOG 2.截断事务日志: B
本文实例讲述了jQuery中clearQueue()方法用法。分享给大家供大家参考。具体分析如下:此方法能够清空对象上尚未执行的所有队列。如果不带参数,则默认清
本文章主要内容为Access数据库中使用SQLServer语句,以下SQLServer语句在ACCESSXP的查询中测试通过。 建表:CreateTabl
本文实例讲述了C#处理Access中事务的方法。分享给大家供大家参考。具体如下:Access不能像SQLserver一样直接执行多条语句,但是把多条语句绑成事务