Re: Using Qpid Proton 0.4 to iterate over arbitrary AMQP message

2013-07-24 Thread amqp1
Thanks, Rafael, I will check the Python doc. Thinking of the message structure as a tree makes it easier to grasp what the function names mean. Does enter/exit make sense for arrays? Are composite types nestable? (Sorry for the dumb questions, I am getting up to speed with AMQP.) Hopefully, I'll

Re: Using Qpid Proton 0.4 to iterate over arbitrary AMQP message

2013-07-24 Thread Rafael Schloming
Have you found/read this documentation?: http://qpid.apache.org/releases/qpid-proton-0.4/protocol-engine/python/api/proton.Data-class.html It's for the python binding to the API, but the background it gives should be useful for understanding the model behind the C API as well. I believe all you w

Re: Using Qpid Proton 0.4 to iterate over arbitrary AMQP message

2013-07-24 Thread Darryl L. Pierce
On Tue, Jul 23, 2013 at 01:59:19PM -0700, amqp1 wrote: > Oh yes, I posted this via the Web interface...don't know why it didn't make > it into the list... > > pn_data_t *body = pn_message_body(amqpMessage); > > while (pn_data_next(body)) > { > pn_type_t type = pn_data_type(bod

Re: Qpid throwed WSAENOBUFS while receiving data from a broker

2013-07-24 Thread Steve Huston
The original poster didn't send a test case or open a jira so it hasn't been worked on. Steve Huston (sent from my iPhone - please excuse brevity and typos) On Jul 24, 2013, at 12:49 PM, "Hamid.Shahid" wrote: > Hi Gene / Steve, > > We are having this issue once or twice every week in QPID 0.

RE: Qpid throwed WSAENOBUFS while receiving data from a broker

2013-07-24 Thread Hamid.Shahid
Hi Gene / Steve, We are having this issue once or twice every week in QPID 0.18 windows client. Have you guys got a chance to test this after increasing BufferCount in qpid/cpp/src/qpid/sys/AsynchIO.h? If yes, can you please share patch? Thank you! - Hamid - Best Regards, Hamid. -- Vi

Re: JMS API failover

2013-07-24 Thread pela
Hi Phil, I understand I have to call the QPID concrete implementation of the JMS Connection, rather than the Connection interface itself which does not offer this functionality. To recap, I need to be handle the following connection events: 1) First connection is established successfully. I can'

Re: JMS API failover

2013-07-24 Thread Phil Harvey
Hi Marco, Try this: ((AMQConnection)yourJmsConnection).setConnectionListener( new org.apache.qpid.jms.ConnectionListener() { ... public void failoverComplete() { ... } ... } Phil On 24 July 2013 09:26, pela wrote: > Hi, > > I'm building a client with JMS API and want

JMS API failover

2013-07-24 Thread pela
Hi, I'm building a client with JMS API and want to achieve automatic reconnection mechanism, that is when the connection to the broker is lost the client should reconnect automatically, resubscribe queues, etc. I've added failover=roundrobin to my connection URL and that seems to work even thoug