kevin obrien

kevin obrien

  • NA
  • 3
  • 2.4k

WCF Service not Processing MSMQ Message

Aug 31 2012 10:03 AM
Hi,

I have a WCF Windows Service that checks for MSMQ messages.
It picks the messages up ok but the ProcessMSMQMessage event does not seem to get called.

Any ideas why this is? Have I set ProcessMSMQMessage event correctly? Or am I missing something?

My code is below. Thanks.

WCF Service Class...

  public partial class MyService : ServiceBase
  {
  private ServiceHost host;

  public MyService()
  {
  InitializeComponent();
  }

  protected override void OnStart(string[] args)
  {
  string queueName = ConfigurationManager.AppSettings["ProcessMsgQueueName"];
  if (!MessageQueue.Exists(queueName))
  {
  MessageQueue thisQueue = MessageQueue.Create(queueName, true);
  thisQueue.SetPermissions("Everyone", MessageQueueAccessRights.ReceiveMessage);
  }

  try
  {
  Uri serviceUri = new Uri("msmq.formatname:DIRECT=OS:" + queueName);
  //host = new ServiceHost(typeof(MyService.Service1), serviceUri);
  //host.Open();

  // communicate to MSMQ how to transfer and deliver the messages
  MsmqIntegrationBinding serviceBinding = new MsmqIntegrationBinding();
  serviceBinding.Security.Transport.MsmqAuthenticationMode = MsmqAuthenticationMode.None;
  serviceBinding.Security.Transport.MsmqProtectionLevel = System.Net.Security.ProtectionLevel.None;

  serviceBinding.SerializationFormat = MsmqMessageSerializationFormat.Binary;

  host = new ServiceHost(typeof(MyService.Service1)); // add watcher class name
  host.AddServiceEndpoint(typeof(MyService.IService1), serviceBinding, serviceUri);
  host.Open();
  }
  catch (Exception ex)
  {
  EventLog.WriteEntry("SERVICE" + ex.Message, EventLogEntryType.Error);
  }
  }

  protected override void OnStop()
  {
  if (host != null)
  host.Close();
  }
  }


IService1 Contract...

  [ServiceContract(Namespace = "MyService")]
  [ServiceKnownType(typeof(Events.Dashboard_Message))]
  public interface IService1
  {
  [OperationContract(IsOneWay = true)]
  void ProcessMSMQMessage(MsmqMessage<Events.Dashboard_Message> msg);
  }


Service1 Class...

  public class Service1 : IService1
  {
  [OperationBehavior(TransactionScopeRequired = true, TransactionAutoComplete = true)]
  public void ProcessMSMQMessage(MsmqMessage<Events.Dashboard_Message> msg)
  {
  string msgName = msg.GetType().Name;

  // send to database
  EventLog.WriteEntry("MyService", msgName); 
  }
  }

Answers (1)