Как установить приоритет на стороне клиента MSMQ сообщение, отправленное на службу WF, активированную через MQ

Question

У меня установка Actied Workflow Workflow (XAMLX) (размещена с использованием WorkflowserviceHost).

Этот WCF WebService имеет «NetMSMQBinding» привязка и конечная точка Net.msmq, которая используется клиентами для расписания операций.

На стороне клиента я использовал Visual Studio для создания прокси-заглушки для связи с этой службой WCF.Все работает нормально, и я вижу сообщения, появляющиеся в моем (журнал) MQ на сервере и WCF, собирая сообщения из очереди, чтобы активировать настроенный рабочий процесс на основе сообщения.

Мне нужно контролировать приоритет отправляемых сообщений в MQ, чтобы некоторые клиенты WCF могут получить приоритетную обработку своих рабочих процессов.

Кажется netmsmqbinding не поддерживает приоритету сообщения MQ.Это правильно?Если это так, как я могу добиться / имитировать это?Могу ли я использовать MQ триггеры для изменения приоритета сообщений на основе некоторых флагов?

Answer 1

Posting my solution, in case someone needs to figure this out

NetMSMQBinding does not support setting message priority from the client side so I was using the wrong binding. The more powerful MsMqIntegrationBinding is the right way to go.

Client side: From the client side, one needs to simply create a System.Messaging.Message object, set the priority and drop it in the MessageQueue.MessageQueue object which points to the destination MQ.

Server side: The WorkflowService hosting WCF project needs the following endpointBinding in the web.config:

---

<endpoint address="msmq.formatname:DIRECT=OS:.\private$\MyWebService/MyProcessingService.xamlx" binding="msmqIntegrationBinding" bindingConfiguration="MyMsMqIntegrationBinding" contract="IMyProcessingService" name="MqIntegrationBindingEndPoint" />

(the address is assuming MQ service is local to the WCF hosted)

<bindings> <!--We use msmqIntegrationBinding instead of netMsmqBinding since we want to control priority of MQ messages being dropped in the queue and that is not supported in netMsmq --> <msmqIntegrationBinding> <binding name="MyMsMqIntegrationBinding" exactlyOnce="false"> <security mode="None" /> </binding> </msmqIntegrationBinding>

---

The way to receive the MsmqMessage from the MQ and process it is by dropping a "Receive" activity in the XAMLX and choosing Message as the Content definition MessageType as System.ServiceModel.MsmqIntegrationMessage<YourTypeGoesHere> Now you'll have access to this MsmqMessage<yourType> from your ActivityContext where you can retrieve the value sent in the message.

This is a very useful and powerful way to build a scalable, throttled with priority control MQ+WCF+WF based web service

Answer 2

Are these transactional messages? If so, you cannot change the priority at all.

Messages are immutable so you can't change the priority of a non-transactional message that has already been sent.

Cheers
John Breakwell