Service Broker - 如何将消息响应到不同的队列
Service Broker - How to response the message to different queue
我是 Service Broker 的新手
消息类型
CREATE MESSAGE TYPE [http://ssb.csharp.at/SSB_Book/c03/RequestMessage]
VALIDATION = WELL_FORMED_XML
GO
CREATE MESSAGE TYPE [http://ssb.csharp.at/SSB_Book/c03/ResponseMessage]
VALIDATION = WELL_FORMED_XML
GO
合同
CREATE CONTRACT [http://ssb.csharp.at/SSB_Book/c03/HelloWorldContract]
(
[http://ssb.csharp.at/SSB_Book/c03/RequestMessage] SENT BY INITIATOR,
[http://ssb.csharp.at/SSB_Book/c03/ResponseMessage] SENT BY TARGET
)
GO
队列
CREATE QUEUE InitiatorQueue
WITH ACTIVATION
(
STATUS = ON,
PROCEDURE_NAME = [ProcessResponseMessage],
MAX_QUEUE_READERS = 1,
EXECUTE AS SELF
)
CREATE QUEUE TargetQueue
WITH ACTIVATION
(
STATUS = ON,
PROCEDURE_NAME = [ProcessRequestMessage],
MAX_QUEUE_READERS = 1,
EXECUTE AS SELF
)
服务
CREATE SERVICE InitiatorService
ON QUEUE InitiatorQueue
(
[http://ssb.csharp.at/SSB_Book/c03/HelloWorldContract]
)
GO
CREATE SERVICE TargetService
ON QUEUE TargetQueue
(
[http://ssb.csharp.at/SSB_Book/c03/HelloWorldContract]
)
GO
上面的代码是示例。
问题是我想将消息响应到另一个队列(例如 ErrorQueue)而不是 InitiatorQueue。我对 Google 进行了研究,但找不到与我的问题相关的任何资源。
我有一些想法,但不知道它是否有效:
- 在合同中添加另一种消息类型:
[http://ssb.csharp.at/SSB_Book/c03/ErrorMessage] SENT BY INITIATOR
但是不知道是设置成INITIATOR, TARGET还是ANY
- 为其创建另一个合同,如果这是解决方案,请提供示例。
谢谢
队列中处理消息的事物可以选择要做什么。如果您想发送到不同的队列,则需要发送不同的对话,因为发送与原始消息所在的对话相同的对话会将其发送回发送消息的位置。您将需要另一种消息类型、合同、队列和服务来将错误消息发送到。让我知道这是否不足以让您继续前进,我可以进一步详细说明。
我是 Service Broker 的新手
消息类型
CREATE MESSAGE TYPE [http://ssb.csharp.at/SSB_Book/c03/RequestMessage]
VALIDATION = WELL_FORMED_XML
GO
CREATE MESSAGE TYPE [http://ssb.csharp.at/SSB_Book/c03/ResponseMessage]
VALIDATION = WELL_FORMED_XML
GO
合同
CREATE CONTRACT [http://ssb.csharp.at/SSB_Book/c03/HelloWorldContract]
(
[http://ssb.csharp.at/SSB_Book/c03/RequestMessage] SENT BY INITIATOR,
[http://ssb.csharp.at/SSB_Book/c03/ResponseMessage] SENT BY TARGET
)
GO
队列
CREATE QUEUE InitiatorQueue
WITH ACTIVATION
(
STATUS = ON,
PROCEDURE_NAME = [ProcessResponseMessage],
MAX_QUEUE_READERS = 1,
EXECUTE AS SELF
)
CREATE QUEUE TargetQueue
WITH ACTIVATION
(
STATUS = ON,
PROCEDURE_NAME = [ProcessRequestMessage],
MAX_QUEUE_READERS = 1,
EXECUTE AS SELF
)
服务
CREATE SERVICE InitiatorService
ON QUEUE InitiatorQueue
(
[http://ssb.csharp.at/SSB_Book/c03/HelloWorldContract]
)
GO
CREATE SERVICE TargetService
ON QUEUE TargetQueue
(
[http://ssb.csharp.at/SSB_Book/c03/HelloWorldContract]
)
GO
上面的代码是示例。
问题是我想将消息响应到另一个队列(例如 ErrorQueue)而不是 InitiatorQueue。我对 Google 进行了研究,但找不到与我的问题相关的任何资源。
我有一些想法,但不知道它是否有效:
- 在合同中添加另一种消息类型:
[http://ssb.csharp.at/SSB_Book/c03/ErrorMessage] SENT BY INITIATOR
但是不知道是设置成INITIATOR, TARGET还是ANY - 为其创建另一个合同,如果这是解决方案,请提供示例。
谢谢
队列中处理消息的事物可以选择要做什么。如果您想发送到不同的队列,则需要发送不同的对话,因为发送与原始消息所在的对话相同的对话会将其发送回发送消息的位置。您将需要另一种消息类型、合同、队列和服务来将错误消息发送到。让我知道这是否不足以让您继续前进,我可以进一步详细说明。