WCF MsmqIntegrationBinding - не отбирает сообщения из очереди - PullRequest
Новая
       6

WCF MsmqIntegrationBinding - не отбирает сообщения из очереди

1 голос
/ 23 декабря 2011

У меня есть устаревший клиент, который пишет сообщения в очередь (MSMQ).Я хотел использовать службу WCF, чтобы забрать XML-сообщения из очереди.Я следовал за некоторыми документами MSFT и искал другие примеры, но я не могу заставить его работать.Хост службы запускается, но он не запускает мой процесс и не отбирает сообщения из очереди.Скорее всего ошибка пользователя, просто не уверен что.

Я вижу сообщения в очереди?

Пример кода: 

   [ServiceContract]
    [ServiceKnownType(typeof(XElement))]
    public interface IMessageProcessor
    {
        [OperationContract(IsOneWay = true, Action = "*")]
        void ProcessMessage(MsmqMessage<XElement> msg);
    }
    class MessageServiceClient : IMessageProcessor
    {
        [OperationBehavior(TransactionScopeRequired = true, TransactionAutoComplete = true)]
        public void ProcessMessage(MsmqMessage<XElement> msg)
        {
            using (TransactionScope scope = new TransactionScope(TransactionScopeOption.Required))
            {
                Console.WriteLine("Processing {0} ", msg.ToString());
                scope.Complete();
            }

        }

        static void Main(string[] args)
        {
            Uri baseAddress = new Uri(ConfigurationManager.AppSettings["baseAddress"]);
            // Create a ServiceHost for the CalculatorService type and provide the base address.
            using (ServiceHost serviceHost = new ServiceHost(typeof(MessageServiceClient), baseAddress))
            {
                // Open the ServiceHostBase to create listeners and start listening for messages.
                serviceHost.Open();

                // The service can now be accessed.
                Console.WriteLine("The service is ready.");
                Console.WriteLine("The service is running in the following account: {0}");
                Console.WriteLine("Press <ENTER> to terminate service.");
                Console.WriteLine();
                Console.ReadLine();

                // Close the ServiceHostBase to shutdown the service.
                serviceHost.Close();
            }
        }
    }

Настройка приложения: 

<?xml version="1.0" encoding="utf-8" ?>
<configuration>
  <appSettings>
    <!-- use appSetting to configure MSMQ queue name -->
    <add key="QueueName" value=".\private$\MyMessageQueue" />
    <add key="baseAddress" value="http://localhost:8000/test/message" />
  </appSettings>
  <system.serviceModel>
    <services>
      <service name="MessageServiceClient">
        <!-- .Net endpoint-->
        <endpoint address="msmq.formatname:DIRECT=OS:.\private$\MyMessageQueue"
                  binding="msmqIntegrationBinding"
                  bindingConfiguration="DotNetBinding"
                  contract="WcfServiceClient.IMessageProcessor" />
      </service>
    </services>
    <behaviors>
      <serviceBehaviors>
        <behavior name="MessageServiceBehavior">
          <serviceDebug includeExceptionDetailInFaults="true" />
          <serviceMetadata />
          <!--<serviceThrottling maxConcurrentCalls="20" maxConcurrentSessions="20" />-->
          <serviceTimeouts />
        </behavior>
      </serviceBehaviors>
    </behaviors>
    <bindings>
      <msmqIntegrationBinding>
        <binding serializationFormat="ActiveX" name="ActiveXBinding" durable="false" exactlyOnce="false">
          <security mode="None" />
        </binding>
        <binding serializationFormat="Xml" name="DotNetBinding" durable="false" exactlyOnce="false">
          <security mode="None" />
        </binding>
      </msmqIntegrationBinding>
    </bindings>
  </system.serviceModel>
</configuration>

Не уверен, что я делаю не так?

- S

1 Ответ

3 голосов
/ 23 декабря 2011

В вашей конфигурации следующий элемент должен быть таким, как показано ниже: 

<services>
      <service name="WcfServiceClient.MessageServiceClient">
        <!-- .Net endpoint-->
        <endpoint address="msmq.formatname:DIRECT=OS:.\private$\MyMessageQueue"  
                  binding="msmqIntegrationBinding"
                  bindingConfiguration="DotNetBinding"
                  contract="WcfServiceClient.IMessageProcessor" />
      </service>
    </services>

Ваше имя службы выше не включает в себя пространство имен, оно всегда должно быть полностью квалифицированным именем службы

...