My implementation of the CCR is going really well and it's great to see new versions coming out every month.
I have an issue that is niggling at me though and it's to do with the ProcessedTaskCount of a Dispatcher. I have a long running Windows Service that has 1 Dispatcher and multiple Dispatcher Queues. The service is quite busy, so the ProcessedTaskCount goes
up quite quickly. Given that ProcessTaskCount is an Int32, it's not unreasonable that over some time I will hit the Int32.MaxValue and the ccr will then bring my AppDomain down. Does this value recycle before it reaches Int32.MaxValue?
I think I'm getting the whole CCR thing bit by bit.
What would nail it for me is if I could do the following.
I have a logging application which must send emails either when a certain number have amounted - or a certain time period occurs. So if I have 5 log entries OR 5 minutes occur, then I need to send everything in the port.
This leads obviously to a Choice Arbiter with a Timer and a MultipleItemReceive. However, since a choice cannot be persisted, how could I keep this chain of events going after either event has occured for the first time?
This library looks fantastic if a little dautning to get your head around. You must be a very satisfied developer indeed )
That darned Ritcher just released his PowerThreading Library with lots of Async goodness that I did'nt quite get how to use and now there's CCR!!
Anyway, I kind of get it but I just wanted to check one thing regarding the persitent nature of Queues. If I post a number of Items to a port and then Activate it on a Receive handler without persitency, am I right in saying that only one item will be processed?
I was thinking that perhaps it would process all items in the port already but just ignore the ones addedd after the Arbiter was started.
Many thanks, keep the example code coming if you don't mind and full marks to Stacey and crew for picking this stuff up so quick.
PS. I'd love to see a full working project of reading an arbitary amount of bytes from an async socket.