I am not sure that I am following what you mean by that.This test pass:
[Fact]
public void CanReceiveFromQueue()
{
for (int i = 0; i < 2; i++)
{
new Sender
{
Destination = new Endpoint("localhost", 23456),
Failure = exception => Assert.False(true),
Success = () => null,
Messages = new[]
{
new Message
{
Id = MessageId.GenerateRandom(),
Queue = "h",
Data = Encoding.Unicode.GetBytes("hello-" + i),
SentAt = DateTime.Now
},
}
}.Send();
}
var longTx = new ManualResetEvent(false);
var wait = new ManualResetEvent(false);
ThreadPool.QueueUserWorkItem(state =>
{
using (var tx = new TransactionScope())
{
queueManager.Receive("h", null);
longTx.WaitOne();
tx.Complete();
}
wait.Set();
});
using (var tx = new TransactionScope())
{
var message = queueManager.Receive("h", null);
Assert.Equal("hello-1", Encoding.Unicode.GetString(message.Data));
tx.Complete();
}
longTx.Set();
wait.WaitOne();
}
On Fri, Apr 17, 2009 at 11:29 PM, Corey Kaylor <[email protected]> wrote:
> I might be having a case of the stupids here, but we have a fairly
> comprehensive sample of sending out 10 messages where the first message
> consumer sleeps for 10 seconds and no replies are received until that
> consumer has replied as well. Our configuration setting is 5 for the thread
> count. Am I missing something?
>
> >
>
--~--~---------~--~----~------------~-------~--~----~
You received this message because you are subscribed to the Google Groups
"Rhino Tools Dev" group.
To post to this group, send email to [email protected]
To unsubscribe from this group, send email to
[email protected]
For more options, visit this group at
http://groups.google.com/group/rhino-tools-dev?hl=en
-~----------~----~----~----~------~----~------~--~---
