Several queues on direct proton receiver?

2015-11-04 Thread Michael Ivanov
Hallo, I have a question about direct message receive in proton. I tried to receive messages directly using amqp://~1.2.3.4 url. It works but it seems that queue names in this case are ignored. I.e. when I subscribe to amqp://~1.2.3.4/q1 I also get the messages for amqp://~1.2.3.4/q2, q3 etc.

Re: Proton 0.11.0 release update - Alpha is available

2015-10-27 Thread Michael Ivanov
Please can you check "Possible typo in messenger.c" message? Is this a real typo? (this is present in earlier versions also, not just in 0.11) Also I observe library looping in the following code: #0 pn_selector_select (selector=0x22bff80, timeout=60) at

Re: proton crash in pn_messenger_free()

2015-10-19 Thread Michael Ivanov
Hallo, I have investigated the crash a bit further. I have added decref/incref trace printout and I got the following at the moment of crash: COLLECTOR 0xba9050 FREE COLLECTOR 0xba9050 RELEASE COLLECTOR 0xba9050 DRAIN COLLECTOR 0xba9050 POP: event 0xbcdd10/pn_link PN_OBJ_DECREF: object 0xbcdd10

Re: proton crash in pn_messenger_free()

2015-10-16 Thread Michael Ivanov
It's still the same in proton 0.10 The line numbers are a bit different, but the error seems to be the same: ==6040== Invalid read of size 8 ==6040==at 0x53679F5: pn_object_reify (object.c:216) ==6040==by 0x5367BA6: pn_class_decref (object.c:92) ==6040==by 0x5375BBF:

proton crash in pn_messenger_free()

2015-10-13 Thread Michael Ivanov
Hallo, I am using proton 0.91 and I constantly experience crashes on process termination. I use two messengers, one to read primary input queue and the other to send replies. Primary messenger is used in non-blocking mode. On termination I do the following: if (_reply) {

proton 0.10 and swiftmq router

2015-10-02 Thread Michael Ivanov
Hallo, I am trying to run proton 0.10 client with SwiftMQ router and I'm getting the following errors: 3 2015-10-02 15:24:08.42/sys$amqp/ERROR/VersionedConnection, connection=127.0.0.1:55984/wrong header received: [ProtocolHeader, name=AMQP, id=0, major=1, minor=0, revision=0], required:

How to get the message representation in encoded form?

2015-07-14 Thread Michael Ivanov
Hallo, I am receiving the qpid message is one process, but would like to actually decode it in a different process. I it possible to use proton to get the message in the unpacked binary form, then copy the buffer over to another process (eg. using pipe) and unpack it to actual pn_message_t

Re: pn_data_grow() issue

2015-05-28 Thread Michael Ivanov
Sorry, how do I create a JIRA issue? 27.05.2015 16:48, Alan Conway пишет: On Tue, 2015-05-26 at 23:25 +0300, Michael Ivanov wrote: Greetings, I have observed that pn_data_grow() function looses half of the available data capacity. The following happens: when data overflows, pn_data_grow

pn_data_grow() issue

2015-05-26 Thread Michael Ivanov
Greetings, I have observed that pn_data_grow() function looses half of the available data capacity. The following happens: when data overflows, pn_data_grow is invoked. It increases data capacity 2 times and reallocates nodes array. Data capacity is represented as uint16_t type and so when

Selectables usage

2015-05-06 Thread Michael Ivanov
Hallo, I am trying to integrate protom messenger with a regular select-based event loop. Regrettably there's not much documentation about reading and sendingn messages in passive mode using selectros. Can you give a quick look to the pseudo-code, describing message input in my event loop

Re: VOTE: Release Proton 0.8 RC4 as 0.8 final

2014-10-25 Thread Michael Ivanov
suspect the most useful one will be the broker trace, so I would appreciate any effort you can make to obtain it. Thanks, --Rafael On Fri, Oct 24, 2014 at 3:40 PM, Michael Ivanov iv...@logit-ag.de wrote: Ok I have some results. Now the core is not dumped but I have unusual delays during

Re: VOTE: Release Proton 0.8 RC4 as 0.8 final

2014-10-24 Thread Michael Ivanov
Hallo, I used proton 0.7 and later when I had an error, proton 0.8 RC4 to build qpid-cpp-0.30. In both cases at some time qpidd aborts in proton library in the following location: #0 0x003999432635 in raise () from /lib64/libc.so.6 #1 0x003999433e15 in abort () from /lib64/libc.so.6

Re: VOTE: Release Proton 0.8 RC4 as 0.8 final

2014-10-24 Thread Michael Ivanov
return the error to fail the connection (assumed - totally untested). -K - Original Message - From: Michael Ivanov iv...@logit-ag.de To: proton@qpid.apache.org Sent: Friday, October 24, 2014 9:38:54 AM Subject: Re: VOTE: Release Proton 0.8 RC4 as 0.8 final Hallo, I used proton 0.7

Re: VOTE: Release Proton 0.8 RC4 as 0.8 final

2014-10-24 Thread Michael Ivanov
? If the problem still occurs (I expect it will, just not quite so fatally) it would be good to get the protocol trace for both the client and the server and see if that will shed some light on what is going on. --Rafael On Fri, Oct 24, 2014 at 2:00 PM, Michael Ivanov iv...@logit-ag.de wrote

Re: VOTE: Release Proton 0.8 RC4 as 0.8 final

2014-10-24 Thread Michael Ivanov
this on the server side as well in order to get the server's version of the protocol trace. --Rafael On Fri, Oct 24, 2014 at 2:31 PM, Michael Ivanov iv...@logit-ag.de wrote: Sorry, should I check out the trunk from the repository or can I download the new sources tar archive from somewhere

Re: VOTE: Release Proton 0.8 RC4 as 0.8 final

2014-10-24 Thread Michael Ivanov
one will be the broker trace, so I would appreciate any effort you can make to obtain it. Thanks, --Rafael On Fri, Oct 24, 2014 at 3:40 PM, Michael Ivanov iv...@logit-ag.de wrote: Ok I have some results. Now the core is not dumped but I have unusual delays during application startup