Jason, Are you using the JMS client or did you try to use the low level classes and work at the AMQP level? If you did try the latter could you please post your client code?
Also please note that these classes may change btw AMQP versions as in the java side we only support the JMS API. Is there a reason why you didn't use JMS? Regards, Rajith On Mon, Mar 23, 2009 at 4:14 PM, Jason Copeland <[email protected]> wrote: > I'm playing with the head (rev 757523 synced as of today) and I'm having > issues w/ clustering turned on. > > Currently I only have one system in the cluster, and the broker will segfault > when trying to connect from a Java client (also synced from head). > > When it sends ProtocolHeader(1,0,10) the broker looks like: > > 2009-mar-23 13:06:42 debug ManagementBroker added package > org.apache.qpid.cluster > 2009-mar-23 13:06:42 debug ManagementBroker added class > org.apache.qpid.cluster:cluster > 2009-mar-23 13:06:42 debug 10.59.174.186:26480(INIT) config change: > 10.59.174.186:26480 > 2009-mar-23 13:06:42 info No message store configured, persistence is > disabled. > 2009-mar-23 13:06:42 notice SASL disabled: No Authentication Performed > 2009-mar-23 13:06:42 notice Listening on TCP port 5672 > 2009-mar-23 13:06:42 info Registered replication exchange > 2009-mar-23 13:06:42 notice 10.59.174.186:26480(INIT) joining cluster renga > with url=amqp:tcp:10.59.174.186:5672 > 2009-mar-23 13:06:42 info Policy file not specified. ACL Disabled, no ACL > checking being done! > 2009-mar-23 13:06:42 info SSL plugin not enabled, you must set > --qpid-ssl-cert-db to enable it. > 2009-mar-23 13:06:42 notice Broker running > [New Thread 0xb616cb90 (LWP 26486)] > 2009-mar-23 13:06:42 trace 10.59.174.186:26480(INIT) DLVR: > Event[10.59.174.186:26480-0 control 28 bytes] > [New Thread 0xb576bb90 (LWP 26487)] > 2009-mar-23 13:06:42 trace 10.59.174.186:26480(INIT) DLVR: Frame[BEbe; > channel=0; {ClusterConfigChangeBody: current=\xBA\xAE; > \x00\x00gp; }] control 10.59.174.186:26480-0 > 2009-mar-23 13:06:42 debug 10.59.174.186:26480(INIT) cluster-id = > 82e10fab-06d6-4f3a-956f-356f2af313e4 > 2009-mar-23 13:06:42 debug Queue events enabled > 2009-mar-23 13:06:42 info 10.59.174.186:26480(READY) member update: > 10.59.174.186:26480(member) > 2009-mar-23 13:06:42 notice 10.59.174.186:26480(READY) first in cluster > 2009-mar-23 13:06:51 debug RECV [153.32.224.133:3035] INIT(0-10) > 2009-mar-23 13:06:51 debug SASL: No Authentication Performed > 2009-mar-23 13:06:51 debug 10.59.174.186:26480(READY) new connection: > 10.59.174.186:26480-1(local) > 2009-mar-23 13:06:51 trace SENT 153.32.224.133:3035 INIT(0-10) > 2009-mar-23 13:06:51 trace SENT [153.32.224.133:3035]: Frame[BEbe; channel=0; > {ConnectionStartBody: > server-properties={qpid.federation_tag:V2:36:str16(b045d881-63e1-49e4-bdb7-07cece6c1e2f)}; > mechanisms=str16{V2:9:str16(ANONYMOUS), V2:5:str16(PLAIN)}; > locales=str16{V2:5:str16(en_US)}; }] > 2009-mar-23 13:06:52 trace MCAST Event[10.59.174.186:26480-1 data 3 bytes] > 2009-mar-23 13:06:52 trace 10.59.174.186:26480(READY) DLVR: > Event[10.59.174.186:26480-1 data 3 bytes] > > Program received signal SIGSEGV, Segmentation fault. > 0x00ca6941 in qpid::framing::AMQFrame::getMethod (this=0xbfe082ac) at > ./qpid/framing/AMQFrame.h:51 > 51 const AMQMethodBody* getMethod() const { return > getBody()->getMethod(); } > > Note in this scenario getBody() is null and thus exceptions. > > The top level of the stack trace looks like: > > 0 0x00ca6941 in qpid::framing::AMQFrame::getMethod (this=0xbfe082ac) at > ./qpid/framing/AMQFrame.h:51 > #1 0x00efbc86 in qpid::cluster::Decoder::process (this=0x92b9d50, > e...@0xbfe0829c) at qpid/cluster/Decoder.cpp:55 > #2 0x00efbfe7 in qpid::cluster::Decoder::decode (this=0x92b9d50, > e...@0x92bb088, data=0x92bc1f1 "\017") at qpid/cluster/Decoder.cpp:50 > #3 0x00ed50e2 in qpid::cluster::Cluster::deliveredEvent (this=0x92b9858, > e...@0x92bb088) at qpid/cluster/Cluster.cpp:251 > > I feel like I'm doing something wrong on the most basic level somewhere. But > I assume it is simply sending out the connection start event of which I > assume has no body, etc? I can easily debug around here, but I'm not sure > what I'm supposed to see. Is there supposed to be a body at this point, or > is this simply a case of needing to return a null on the getMethod() function > if getBody() is null? > > Thanks, > Jason > -- Regards, Rajith Attapattu Red Hat http://rajith.2rlabs.com/ --------------------------------------------------------------------- Apache Qpid - AMQP Messaging Implementation Project: http://qpid.apache.org Use/Interact: mailto:[email protected]
