0

WCFを使用してMSMQとの間で送受信したい。FeedWorkerメソッドはMQから(queue1から)メッセージを受け取り、メッセージを処理して結果をに保存するスレッドに渡しますqueue2FeedWorkerそしてProcessCustomer同じプロジェクトで。

public void FeedWorker()
{
    while(true)
    {
        var msg = GetFromMQ();
        ThreadPool.QueueUserWorkItem(ProcessCustomer, msg);
    }
}
public void ProcessCustomer(object o)
{
    // Do some work
    // ...
    SentToMQ(result);
}

これを達成するために、私はを使用して次のことを行うことを考えましたnetMsmqBinding

namespace Test 
{
    public class WcfService : IWcfService
    {
        public void Get(Customer customer)
        {
            ThreadPool.QueueUserWorkItem(ProcessCustomer, customer);
        }
        public void SaveResult(string result)
        { }
    }

    public void FeedWorker()
    {
        using (var serviceHost = new ServiceHost(typeof(WcfService)))
        {
            serviceHost.Open();
        }
    }

    public void ProcessCustomer(object o)
    {
        // Do some work
        // ...
        WcfServiceClient.SaveResult(result);
    }
}

私は何か間違ったことをしているように感じます。そして、私がやったように、私は別のキューに送受信することができません。これを実装する方法は?

4

0 に答える 0