http://ayende.comAyende @ RahienCopyright (C) Ayende Rahien 2004 - 2021 (c) 202660Dev, Please post this to the mailing list http://ayende.com/3931/rhino-queues-take-6#comment28http://ayende.com/3931/rhino-queues-take-6#comment28Thu, 23 Apr 2009 18:43:47 GMThi Ayende im doing some tests with the latest src on svn and i have a prob first i start a server with: using (var tx = new TransactionScope()) { receiver = new QueueManager(new IPEndPoint(IPAddress.Loopback, 4545), "werwer.esent"); receiver.CreateQueues("uno"); tx.Complete(); } while (true) { //System.Threading.Thread.Sleep(1000); using (var tx = new TransactionScope()) { var msg = receiver.Receive("uno", null, new TimeSpan(0,0,10)); if (msg != null) { Console.WriteLine(Encoding.ASCII.GetString(msg.Data) +" " + msg.Id); } now in a client i do: using (var tx = new TransactionScope()) { sender = new QueueManager(new System.Net.IPEndPoint(IPAddress.Loopback, 4546), "client.esent"); tx.Complete(); } using (var tx = new TransactionScope()) { sender.Send(new Uri("rhino.queues://localhost:4545/uno"), new MessagePayload { Data = Encoding.ASCII.GetBytes("Message " + x.ToString()) } tx.Complete(); } } } now, i send one msg and receive one in the server then i run it again and receive 3 times the new msg. maybe im missing something there? http://ayende.com/3931/rhino-queues-take-6#comment27http://ayende.com/3931/rhino-queues-take-6#comment27Thu, 23 Apr 2009 18:42:26 GMTthanks for the info... guess i am too stuck in the MSMQ world http://ayende.com/3931/rhino-queues-take-6#comment26http://ayende.com/3931/rhino-queues-take-6#comment26Mon, 06 Apr 2009 17:40:02 GMTRafal, RSB can run on all of those for a while now. MSMQ 3.0 is supported as well. And yes, RQ runs on XP, so that is a positive. http://ayende.com/3931/rhino-queues-take-6#comment25http://ayende.com/3931/rhino-queues-take-6#comment25Sat, 04 Apr 2009 23:44:51 GMTAyende, as far as I remember Rhino Service Bus required windows 2008 because of some functions available only in MSMQ 4.0. With the introduction of Rhino queues will it work on windows 2003, xp or vista? http://ayende.com/3931/rhino-queues-take-6#comment24http://ayende.com/3931/rhino-queues-take-6#comment24Sat, 04 Apr 2009 19:29:15 GMTMike, using for receiver - I think you were talking about my post regarding using and ISession. Different things all together. No, the receiver get a Func{Messages[], IMessageAcceptance}, which is how it let the rest of the app know about new messages. The event is just to facilitate easier testing. The information about the source message is located in the message headers. message.Headers["source"], to be exact. That is beyond the scope of Rhino Queues, it is something that you need to add. http://ayende.com/3931/rhino-queues-take-6#comment23http://ayende.com/3931/rhino-queues-take-6#comment23Sat, 04 Apr 2009 12:52:23 GMTRafal, Thanks, I fixed that. http://ayende.com/3931/rhino-queues-take-6#comment22http://ayende.com/3931/rhino-queues-take-6#comment22Sat, 04 Apr 2009 12:49:27 GMTFrank, I wouldn't call an AVI file a message. And stream is a much better alternative for that. http://ayende.com/3931/rhino-queues-take-6#comment21http://ayende.com/3931/rhino-queues-take-6#comment21Sat, 04 Apr 2009 12:47:47 GMTAyende, With 2GB being arbitrarily large, my customer would beg to differ. They like to send around 4GB avi files in their intranet as if there is no tomorrow. :) Well, no messaging for that one, that project became more of a streaming thing anyway... http://ayende.com/3931/rhino-queues-take-6#comment20http://ayende.com/3931/rhino-queues-take-6#comment20Sat, 04 Apr 2009 12:00:04 GMTNathan, Yes, I am using a private build. But I spoke with Laurion, and he said he would add it to the public build http://ayende.com/3931/rhino-queues-take-6#comment19http://ayende.com/3931/rhino-queues-take-6#comment19Sat, 04 Apr 2009 11:31:06 GMTI know it's bad to optimize the code too early, but I think Reciever should be spelled Receiver http://ayende.com/3931/rhino-queues-take-6#comment18http://ayende.com/3931/rhino-queues-take-6#comment18Sat, 04 Apr 2009 06:21:24 GMTI guess you are using a patched version of the managed Esent API? JetEscrowUpdate doesn't seem to exist on the codeplex version... http://ayende.com/3931/rhino-queues-take-6#comment17http://ayende.com/3931/rhino-queues-take-6#comment17Fri, 03 Apr 2009 22:50:29 GMTinteresting... good stuff a couple of questions well really one question and one note first the note: i noticed in one of your tests that you are newing up a new Reciever object in a "using" statement. didn't you have a post about not too long ago stating that it was bad to do that? just curious now the question: i feel like i am missing something when looking at the code i think that i understand that you have to create a Reciever object and handle the CompletedRecievingMessages event in order to know if a message has been sent to the queue or not i am missing how or where the information is to send a message back is there something in the Message that tells me where the message came from? is that something that i have to add in the Headers? hope the question makes sense http://ayende.com/3931/rhino-queues-take-6#comment16http://ayende.com/3931/rhino-queues-take-6#comment16Fri, 03 Apr 2009 20:26:10 GMTV, One of the planned features is a full stats report from the queue, yes. As for why I create my own, the answer is quite simple, whatever is out there doesn't meet the requirements that I have. RSB was created to be super simple to use, highly opinionated, developer friendly ESB. RQ was created to be xcopy deployed with load balancing friendliness. http://ayende.com/3931/rhino-queues-take-6#comment15http://ayende.com/3931/rhino-queues-take-6#comment15Fri, 03 Apr 2009 17:50:15 GMTRene, Thanks, I fixed that. http://ayende.com/3931/rhino-queues-take-6#comment14http://ayende.com/3931/rhino-queues-take-6#comment14Fri, 03 Apr 2009 17:48:11 GMTJust finished reading the post... i dont know if I like it yet... lol How do you check how many messages are in the queue? Using MSMQ, the operational staff can just check the message count (computer mgmt/services/queues). Are you planning to create services to monitor your queues? Maybe add them to the computer mgmt. just like MSMQ... I never got why you must create your own stuff... looks like everything else has lots of problems... It's your time, I'm not here to judge. I just would like to have a better understanding of your reasons. Maybe you could write a blog post about that. (; A good one woule be a comparison... nServiceBus x Rhino Service Bus x Mass Transit. Rhino Queues x MSMQ x ActiveMQ. I know you have some posts about that, but its never enough. Keep up the good work. http://ayende.com/3931/rhino-queues-take-6#comment13http://ayende.com/3931/rhino-queues-take-6#comment13Fri, 03 Apr 2009 16:28:32 GMTHi ayende thanks for this code, im trying to run the tests and get an error on the chemaCreator.Create Error TaggedNotNULL (JET_errTaggedNotNULL, No non-NULL tagged columns) i found that changing ColumndefGrbit.ColumnNotNULL to ColumndefGrbit.None for columns JET_coltyp.LongText, works fine. im using Windows XP SP3. http://ayende.com/3931/rhino-queues-take-6#comment12http://ayende.com/3931/rhino-queues-take-6#comment12Fri, 03 Apr 2009 16:13:13 GMTRafal, subqueues are freely defined, no need to explicitly create them upfront. James, Me too, feel free to suggest a better name. Yuriy, Talk to MS about that, IPEndpoint is their name. http://ayende.com/3931/rhino-queues-take-6#comment11http://ayende.com/3931/rhino-queues-take-6#comment11Fri, 03 Apr 2009 15:09:13 GMTHorses, Well, yes. It is limited to 2GB, for more than one reason. I consider this to be arbitrarily large :-) http://ayende.com/3931/rhino-queues-take-6#comment10http://ayende.com/3931/rhino-queues-take-6#comment10Fri, 03 Apr 2009 15:06:26 GMTNathan, Not only didn't I do any perf comparisons, I didn't even try to think about perf yet :-) http://ayende.com/3931/rhino-queues-take-6#comment9http://ayende.com/3931/rhino-queues-take-6#comment9Fri, 03 Apr 2009 15:05:22 GMTI guess TCP communication endpoint should be rather named TcpEndpoint, not IPEndpoint, especially since port numbers have nothing to do with raw IP. http://ayende.com/3931/rhino-queues-take-6#comment8http://ayende.com/3931/rhino-queues-take-6#comment8Fri, 03 Apr 2009 09:43:35 GMTI look forward to playing with this. From the code sample, something strikes me right away, the use of the word 'Manager' in classes is a pet hate of mine as it doesn't mean anything. What does the QueueManager really do? Everyone's a critic right?! http://ayende.com/3931/rhino-queues-take-6#comment7http://ayende.com/3931/rhino-queues-take-6#comment7Fri, 03 Apr 2009 07:44:51 GMTCongratulations, hope you're not working on your own operating system yet? Question: can subqueues be freely defined, or are they already pre-defined? Thanks for keeping the API simple... with this addition I'll definitely have a look at Rhino SB. http://ayende.com/3931/rhino-queues-take-6#comment6http://ayende.com/3931/rhino-queues-take-6#comment6Fri, 03 Apr 2009 05:32:18 GMTGreat, will check it out. Hopefully it will make Rhino Service bus easier / more accessible to work with. Microsoft should hire you, they could then retire most their .NET BCL developers :) http://ayende.com/3931/rhino-queues-take-6#comment5http://ayende.com/3931/rhino-queues-take-6#comment5Fri, 03 Apr 2009 05:12:39 GMTPerhaps I'm being facetious, but when you say "arbitrarily large messages", don't you mean messages smaller than 2GB? The length used for message data in SerializationExtensions is only an Int32... http://ayende.com/3931/rhino-queues-take-6#comment4http://ayende.com/3931/rhino-queues-take-6#comment4Fri, 03 Apr 2009 05:09:47 GMTVery, very exciting stuff...can't wait to integrate it into our messaging project. Have you done any performance comparisons? http://ayende.com/3931/rhino-queues-take-6#comment3http://ayende.com/3931/rhino-queues-take-6#comment3Fri, 03 Apr 2009 03:14:59 GMTYes, that is a misprint, it IS available. I fixed the post http://ayende.com/3931/rhino-queues-take-6#comment2http://ayende.com/3931/rhino-queues-take-6#comment2Fri, 03 Apr 2009 01:35:36 GMT"It is not publically available," Did you mean it was 'now publicly available'? I assume that it was a misprint what with the link and all, but since I'm currently looking at Rhino Service Bus, wanted to make sure. TIA. http://ayende.com/3931/rhino-queues-take-6#comment1http://ayende.com/3931/rhino-queues-take-6#comment1Thu, 02 Apr 2009 23:58:33 GMT