Hi all,

I'm having this scenario: A client service sends a message to a router
service which, according to some business rules, determines an actual
processor service. Since those rules are quite complex I decided to host it
inside a Win Service, which on its start method sets up several threads
listening the router service's incoming queue. with the following code:

private static void ConfigThreads()
{
int threadCount = GetThreadCount();
for (int i = 0; i < hilos; threadCount)
{
 ThreadPool.QueueUserWorkItem(new WaitCallback(SetUpListener), null);
}
}

private static void SetUpListener(object context)
{
using (SqlConnection con = GetConnection())
{
 con.Open();
 string serviceName = GetRoutingServiceName();
 RouterService router = new RouterService(serviceName, con);
 service.WaitforTimeout = TimeSpan.FromSeconds(-1);
 service.FetchSize = 1;
 service.Run(true, con, null);
}
}

Inside de DispatchMethod of the RouterService I wrote:

.....................
ProcessorService svc = new ProcessorService(GetRoutingServiceName(), con);
svc.WaitForTimeOut = GetTimeOut();
Conversation conv = svc.BeginDialog(GetProcessingService(), null,
mensaje.ContractName, TimeSpan.FromMinutes(5), true, null, con, tran);
using (Stream streamBody = new MemoryStream(Encoding.UTF8.GetBytes(body)))
{
Message msgCopy = new Message(originalMessage.Type, streamBody);
conv.Send(mensajeNuevo, con, tran);
tran.Commit();
}
tran = con.BeginTransaction();
if (svc.GetConversation(conv, con, tran) == null)
{
response = new Response("Processing")
}
else
{
Message msgResponse = conv.Receive();
if (msgRespuesta.Body != null)
{
 using (StreamReader reader = new StreamReader(msgRespuesta.Body))
 {
  string xmlResp = reader.ReadToEnd();
  resp =
(RespuestaPeticion)SerializationUtil.GetObject<responseType>(xmlResp);
  originalMessage.Conversation.End(con, tran);
 }
}
RegistrarDepuracion("Mensaje deserializado desde el servicio remoto
conversacion {0}", conv.Handle);
}
tran.Commit();
....................

The thing is while this code is waiting for the response from de processing
service ("if (svc.GetConversation(conv, con, tran) == null)") some other
thread in the pool process the response message leading to a "message
starving", so all the clients are getting the "processing" response message.
I don´t understand why the other thread reads the response message since the
original thread hasn't finished its operation (it is inside the service::run
method which RECEIVE'S command transaction hasn't commited yet) and
therefore its conversation group should be locked.  A workaround to this
issue is to have another service/queue pair dedicated only to receive the
response messages with no thread/readers associated.

Any advice would be greatly appreciated,I'm not sure what am I missing here.

Regards,

Ramiro Calderon