Hi Rob, I was able to debug AMQP 0-10 message publishing flow with given instructions. I really appreciate your help. :-)
Cheers! On Thu, Mar 10, 2016 at 12:17 PM, Rob Godfrey <[email protected]> wrote: > So given the above settings I *think* you are using the qpid-client which > is bundled in the Qpid Java release. This client speaks AMQP 0-8/0-9/0-9-1 > and 0-10. There is a separate qpid-jms client which speaks AMQP 1.0. By > default the client will connect using the most recent version of the > protocol that both client and broker support - which in your case would be > AMQP 0-10. This being the case, the control flow will never go through > AMQChannel. The equivalent point in the 0-10 flow would be > org.apache.qpid.server.protocol.v0_10.ServerSession#enqueue(...) > > Hope this helps, > Rob > > On 10 March 2016 at 03:28, Indika Sampath <[email protected]> > wrote: > >> Hi Lorenz, >> >> Thanks for the alternative approach. I am also not quite sure why -run:jpda >> not working correctly. I'll further give a try to figure it out. >> >> Hi Rob, >> I didn't specify AMQP protocol version. I am using Apache Jmeter to >> publish and subscribe. Below are the basic properties set in the Jmeter >> script. >> >> jms.initial_context_factory - >> org.apache.qpid.jndi.PropertiesFileInitialContextFactory >> jms.provider_url - path to .jndi property file which has connection >> factory and queue name key value pair >> jms.connection_factory - qpidConnectionfactory >> >> Do I need to explicitly set AMQP protocol version? If I didn't set it, >> then what would be set as default? Could you please let me know how to set >> it up? >> >> Cheers! >> >> On Wed, Mar 9, 2016 at 8:01 PM, Rob Godfrey <[email protected]> >> wrote: >> >>> Which version of the AMQP protocol are you using to publish your >>> messages? >>> >>> AMQChannel is only used for the 0-8, 0-9, and 0-9-1 protocols. >>> If you are using AMQP 0-10 or AMQP 1.0 your breakpoint will never be hit. >>> >>> Cheers, >>> Rob >>> >>> On 9 March 2016 at 12:18, Indika Sampath <[email protected]> >>> wrote: >>> >>> > Hi All, >>> > >>> > I forked qpid [1] and studying the implementation. I was create Jmeter >>> > scripts to publish and subscribe. Those are working fine. So I started >>> to >>> > identify message publishing flow. I am using Intellij Idea community >>> > edition version 15. Project imported to Intellij Idea correctly. Next >>> I set >>> > debug config which is transport to socket and port to 8000. Then start >>> > broker with ./qpid-server -run:jpda. >>> > >>> > I added break point to line inside deliverCurrentMessageIfComplete() >>> method >>> > in AMQChannel. But when I hit the broker by publisher, debug point not >>> > getting executed. Could you please point out correct way of debug code >>> and >>> > identify message publishing flow. >>> > >>> > [1] https://github.com/apache/qpid-java >>> > >>> > Cheers! >>> > >>> >> >> >
