Thanks for the explanation of the receive loop Hiram. I am trying to run the Multiplexor test included in org.jboss.mq.il.uil.multiplexor. For some indiscernible reason, the test is freezing after starting the first stream.
I am trying to run the test under jdk1.4.1_01 -- are there any known compatibility problems? Or can someone verify that the test runs ? Thanks, fawce --------------------------------- John Fawcett CTO, Tamale Software, LLC 26 Fox Road Waltham, MA 02451 -----Original Message----- From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED]] On Behalf Of Hiram Chirino Sent: Friday, January 10, 2003 6:50 PM To: [EMAIL PROTECTED] Subject: RE: [JBoss-dev] JBossMQ Your kinda right. the loop is there for the case where the destination is queue based (p2p and durable subs). The polling happens when the queue is full. Now when the queue is not full (or in the pub sub case, there is no queue), then the thread goes into asynch mode and it waits for the message to get delivered async via the ClientIL.receive method. I'll comment the code a little: // gets the next message in queue or registers us for asynch delivery if none available. mes = session.connection.receive( subscription, 0 ); if ( mes == null ) // should always be null for pub-sub case. { // start waiting for the message to get delivered asynch waitingForMessage = true; while ( ( messages.isEmpty() && !closed ) || ( !session.running ) ) { try { // messages gets signaled once ClientIL.receive finishes processing the message. messages.wait(); } catch ( InterruptedException e ) { } } if ( closed ) { waitingForMessage = false; break outer; } // the message sent via ClientIL.receive should now be sitting in messages mes = ( SpyMessage )messages.removeFirst(); waitingForMessage = false; } I hope that helped! I think the XIL is great idea! We might even be able to develop a c base API to access mq services (important in the integration space). Regards, Hiram > -----Original Message----- > From: [EMAIL PROTECTED] > [mailto:[EMAIL PROTECTED]]On Behalf Of John > Fawcett > Sent: Thursday, January 09, 2003 8:09 PM > To: [EMAIL PROTECTED] > Subject: [JBoss-dev] JBossMQ > > > Hi, > > I am working on a new invocation layer (IL) for JbossMQ that encodes all > communication in Xml (XIL). I've got the IL pretty near completion, and > I am working on a C# jbossmq client. I am trying to develop the > TopicSubsciber, which is an extension of MessageConsumer. In reviewing > the code in the jbossmq java sources, it looks to me like the client to > a topic actually runs a loop sending receive requests to the server > regularly. > > Is this really necessary? Once the connection has been established, why > can't the server just invoke the ClientIL.receive method (which actually > sends the message to the client) when a message arrives at the > destination? > It looks to me like the current implementation is not truly > asynchronous... > What am I missing? > > Thanks, > fawce > > > --------------------------------- > John Fawcett > CTO, Tamale Software, LLC > 26 Fox Road > Waltham, MA 02451 > > > > ------------------------------------------------------- > This SF.NET email is sponsored by: > SourceForge Enterprise Edition + IBM + LinuxWorld = Something 2 See! > http://www.vasoftware.com > _______________________________________________ > Jboss-development mailing list > [EMAIL PROTECTED] > https://lists.sourceforge.net/lists/listinfo/jboss-development ------------------------------------------------------- This SF.NET email is sponsored by: SourceForge Enterprise Edition + IBM + LinuxWorld = Something 2 See! http://www.vasoftware.com _______________________________________________ Jboss-development mailing list [EMAIL PROTECTED] https://lists.sourceforge.net/lists/listinfo/jboss-development ------------------------------------------------------- This SF.NET email is sponsored by: SourceForge Enterprise Edition + IBM + LinuxWorld = Something 2 See! http://www.vasoftware.com _______________________________________________ Jboss-development mailing list [EMAIL PROTECTED] https://lists.sourceforge.net/lists/listinfo/jboss-development
