WCFを使用してMSMQとの間で送受信したい。FeedWorker
メソッドはMQから(queue1から)メッセージを受け取り、メッセージを処理して結果をに保存するスレッドに渡しますqueue2
。FeedWorker
そして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);
}
}
私は何か間違ったことをしているように感じます。そして、私がやったように、私は別のキューに送受信することができません。これを実装する方法は?