创建发送消息用的存储过程.sql

sql broker service 实例

USE InitiatorDB;
GO
create proc SendMsg

as
DECLARE @InitDlgHandle UNIQUEIDENTIFIER;
DECLARE @RequestMsg NVARCHAR(100);
declare @Msg nvarchar(100);

BEGIN TRANSACTION;
select @Msg = Msg from dbo.SendTable
BEGIN DIALOG @InitDlgHandle
     FROM SERVICE [//InitDB/2DBSample/InitiatorService]
     TO SERVICE N'//TgtDB/2DBSample/TargetService'
     ON CONTRACT [//BothDB/2DBSample/SimpleContract]
     WITH
         ENCRYPTION = OFF;

--SELECT @RequestMsg =
--   N'<RequestMsg>Message for Target service.</RequestMsg>';

SELECT @RequestMsg =
   N''+@Msg+'';


SEND ON CONVERSATION @InitDlgHandle
     MESSAGE TYPE [//BothDB/2DBSample/RequestMessage]
      (@RequestMsg);

SELECT @RequestMsg AS SentRequestMsg;

COMMIT TRANSACTION;
GO