pn_messenger_send return code

Hello. I am evaluating Qpid Proton AMQP Messenger to communicate with SwiftMQ broker. I've had issues with receiving messages, but I used suggestion here https://issues.apache.org/jira/browse/PROTON-484 and it solved the problem. The use case I am testing is broker is down. Modified send.c

Re: pn_messenger_send return code

Thanks for your reply. I added the tracker, but with the same scenario it returns 0 which is PN_STATUS_UNKNOWN = 0. - Error 0 read: Connection refused [0x100810800:0] ERROR[-2] SASL header mismatch: '' send: Broken pipe CONNECTION ERROR

Re: pn_messenger_send return code

I didn't insert the line in the code as was suggested by Rafael pn_messenger_set_outgoing_window(messenger, N); With that change I get PN_STATUS_ABORTED = 6 when the link is broken. I do have another problem though. I get the following errors sometimes.. ./send -a

Re: pn_messenger_send return code

A related question regarding subscription API. There are several use cases. A single subscription to invalid queue on a running broker, the messenger is blocking pn_messenger_subscribe(messenger, amqp://guest:guest@127.0.0.1:5772/testqueue2); pn_messenger_rewrite(messenger, amqp://%/*, $2);

Re: SASL / proton-c questions

Andreas, are you planning to fix the bug in the future version? Thanks, Sergejs. -- View this message in context: http://qpid.2158936.n2.nabble.com/SASL-proton-c-questions-tp7602690p7602711.html Sent from the Apache Qpid Proton mailing list archive at Nabble.com.

call pn_messenger_accept from another thread

There are several discussions on this forum regarding multi-threading, and as I understand messenger isn't thread safe. However, my use case is simple. A single thread receives messages, but message processing is handed over to another thread Is it possible to call

Re: call pn_messenger_accept from another thread

Thanks for the answer. Yes, I do have thread safe queue, so I might just follow your suggestion and set up a reverse queue for trackers. Sergey. -- View this message in context: http://qpid.2158936.n2.nabble.com/call-pn-messenger-accept-from-another-thread-tp7602918p7602948.html Sent from the

Qpid Proton messenger on 32 bit linux

Does the messenger work on 32 bit linux? I build the 32 bit messenger by setting the variable export CFLAGS=-m32 The same code that works on 64 bit linux crates on 32. It always crashes in pn_encoder_writef8 Here is the crash stack trace from a core dump Core was generated by `./testconsumer

Re: Qpid Proton messenger on 32 bit linux

I create pthreads, and each thread uses its own messenger, so there is no sharing and no mutexes. The program works however when there is only 1 thread, but crashes immediately when there is mo than one thread. It works in 64 bit mode no matter how many threads I create, but I have to use it in

Re: Qpid Proton messenger on 32 bit linux

I am building on 64 bit RedHat 6.3 that has required 32 bit libraries. It happens when initiated from both pn_messenger_recv() and pn_messenger_send(). -- View this message in context: http://qpid.2158936.n2.nabble.com/Qpid-Proton-messenger-on-32-bit-linux-tp7603445p7603475.html Sent from the

Re: Qpid Proton messenger on 32 bit linux

Do I need to pass any special arguments to cmake or change CMakeLists.txt that may affect Messanger? -- View this message in context: http://qpid.2158936.n2.nabble.com/Qpid-Proton-messenger-on-32-bit-linux-tp7603445p7603477.html Sent from the Apache Qpid Proton mailing list archive at

Re: Qpid Proton messenger on 32 bit linux

The attached example is a send.c http://qpid.2158936.n2.nabble.com/file/n7603555/send.c slightly modified send.c example. It works in 64 bit environment, but crashes when proton is build with export CFLAGS=-m32 . Can you execute it on 32 bit linux? Thanks, Sergey. -- View this message in

Re: Qpid Proton messenger on 32 bit linux

I tried that option and it still crashes. Sergey -- View this message in context: http://qpid.2158936.n2.nabble.com/Qpid-Proton-messenger-on-32-bit-linux-tp7603445p7603614.html Sent from the Apache Qpid Proton mailing list archive at Nabble.com.

Re: Qpid Proton messenger on 32 bit linux

I use Proton with SwiftMQ broker which by default advertises max-frame-size=2147483647. Then realloc fails to allocate a memory region inside pn_buffer_ensure( disp-frame, disp-remote_max_frame) followed by a crash when disp-frame is used. Fortunately max-frame-size is configurable in SwiftMQ. I

Quotes in the message body

I am using Qpid Proton Messenger with SwiftMQ JMS/AMQP broker. On the receiving side the messenger surrounds message body with quotes. smeldris@labitpf2:~/qpid-proton-0.6/build/proton-c/examples/messenger/c./send -a amqp://10.250.0.127:5672/testqueue

Re: Quotes in the message body

Thanks for the explanation. Yes, I used recv client. I had to also call pn_data_next(body) to make it work, so it looks like so -- pn_data_t *body = pn_message_body(message); pn_data_next(body); pn_bytes_t bytes =

Re: proton 0.10 and swiftmq router

If you do not need sasl you can disable it see property sasl-enabled on this page http://www.swiftmq.com/products/router/swiftlets/sys_amqp/config/index.html -- View this message in context: http://qpid.2158936.n2.nabble.com/proton-0-10-and-swiftmq-router-tp7631721p7631970.html Sent from

Assertion `messenger->distributed' failed

Hello. I posted this question to qpid-users, but I didn't get any reply, so I am trying my luck on this sub forum. My requirement is to immediately accept/acknowledge the received message and send the ack to the sender, which in my case SwiftMQ AMQP server Here is what I am roughly doing..