Re: Local transactions support
I checked the qpid roadmap and saw that there is no transactions support for AMQP 1.0 even in latest release. Is it because of proton transactions support lack? Could anybody clarify the situation with transactions (local and distributed) in proton? -- View this message in context: http://qpid.2158936.n2.nabble.com/Local-transactions-support-tp7594523p7594550.html Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
Re: Creating queues with PROTON messenger
Hi, Folks. I still need an example. If messenger cann't create queues or topics, I think it might be possible via low-level proton methods. But I don't familiar enough with AMQP specification. Could anybody help me please? -- View this message in context: http://qpid.2158936.n2.nabble.com/Creating-queues-with-PROTON-messenger-tp7593967p7594491.html Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
Re: Creating queues with PROTON messenger
Yes, I am using ActiveMQ. But it doesn't means. Do you mean that I can create queues only with server specific instruments and there is no ways to create queues via proton lib? -- View this message in context: http://qpid.2158936.n2.nabble.com/Creating-queues-with-PROTON-messenger-tp7593967p7594508.html Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
Re: Creating queues with PROTON messenger
Ted, thank you kindly for complete reply. -- View this message in context: http://qpid.2158936.n2.nabble.com/Creating-queues-with-PROTON-messenger-tp7593967p7594520.html Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
Local transactions support
Does Proton supports local transactions? What shoud I do if I need to send some messages within a transaction? Thanks for help. -- View this message in context: http://qpid.2158936.n2.nabble.com/Local-transactions-support-tp7594523.html Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
Re: Deadlock in pn_messenger_stop? (C Qpid Library)
Hi, Frank. I just had the similar problem. In my case I'm trying to call pn_messenger_stop and the thread hangs. I have only one main thread. So, it seems to be a bug. -- View this message in context: http://qpid.2158936.n2.nabble.com/Deadlock-in-pn-messenger-stop-C-Qpid-Library-tp7594142p7594461.html Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
Re: Does Messenger API supports SSL?
No. I've got an error SASL header mismatch Maybe I have to configure messenger fo ssl? -- View this message in context: http://qpid.2158936.n2.nabble.com/Does-Messenger-API-supports-SSL-tp7593987p7593989.html Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
Re: Does Messenger API supports SSL?
I've just found the problem. Earlier, I compiled proton without SSL support. It was my fail, sorry. But now, I've recompiled proton dll and I've got another error: http://qpid.2158936.n2.nabble.com/file/n7594003/ssl_error.png As for server, I use activemq. While trying to connect to it I see the warning in the server log: WARN | Transport Connection to: tcp://127.0.0.1:1632 failed: javax.net.ssl.SSLHandshakeException: no cipher suites in common. Any ideas? -- View this message in context: http://qpid.2158936.n2.nabble.com/Does-Messenger-API-supports-SSL-tp7593987p7594003.html Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
Re: Does Messenger API supports SSL?
Here it is: CONNECTED(04E4) write to 0x1ec28a0 [0x1ef26a0] (321 bytes = 321 (0x141)) - 16 03 01 01 3c 01 00 01-38 03 03 51 b7 37 bc 04 ...8..Q.7.. 0010 - 28 3c bd 2c 32 55 20 98-ad ef d8 de a2 33 57 30 (.,2U ..3W0 0020 - 81 b0 91 d2 91 a4 ba 10-b7 97 34 00 00 a0 c0 30 ..40 0030 - c0 2c c0 28 c0 24 c0 14-c0 0a c0 22 c0 21 00 a3 .,.(.$..!.. 0040 - 00 9f 00 6b 00 6a 00 39-00 38 00 88 00 87 c0 32 ...k.j.9.8.2 0050 - c0 2e c0 2a c0 26 c0 0f-c0 05 00 9d 00 3d 00 35 ...*=.5 0060 - 00 84 c0 12 c0 08 c0 1c-c0 1b 00 16 00 13 c0 0d 0070 - c0 03 00 0a c0 2f c0 2b-c0 27 c0 23 c0 13 c0 09 ./.+.'.# 0080 - c0 1f c0 1e 00 a2 00 9e-00 67 00 40 00 33 00 32 .g.@.3.2 0090 - 00 9a 00 99 00 45 00 44-c0 31 c0 2d c0 29 c0 25 .E.D.1.-.).% 00a0 - c0 0e c0 04 00 9c 00 3c-00 2f 00 96 00 41 00 07 /...A.. 00b0 - c0 11 c0 07 c0 0c c0 02-00 05 00 04 00 15 00 12 00c0 - 00 09 00 14 00 11 00 08-00 06 00 03 00 ff 01 00 00d0 - 00 6f 00 0b 00 04 03 00-01 02 00 0a 00 34 00 32 .o...4.2 00e0 - 00 0e 00 0d 00 19 00 0b-00 0c 00 18 00 09 00 0a 00f0 - 00 16 00 17 00 08 00 06-00 07 00 14 00 15 00 04 0100 - 00 05 00 12 00 13 00 01-00 02 00 03 00 0f 00 10 0110 - 00 11 00 23 00 00 00 0d-00 22 00 20 06 01 06 02 ...#.. 0120 - 06 03 05 01 05 02 05 03-04 01 04 02 04 03 03 01 0130 - 03 02 03 03 02 01 02 02-02 03 01 01 00 0f 00 01 0140 - 01. read from 0x1ec28a0 [0x1ef7c00] (7 bytes = 7 (0x7)) - 15 03 03 00 02 02 28 ..( --- no peer certificate available --- No client certificate CA names sent --- SSL handshake has read 7 bytes and written 321 bytes --- New, (NONE), Cipher is (NONE) Secure Renegotiation IS NOT supported Compression: NONE Expansion: NONE --- Thanks for help. -- View this message in context: http://qpid.2158936.n2.nabble.com/Does-Messenger-API-supports-SSL-tp7593987p7594015.html Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
Re: Receiving messages with PROTON messenger
You unserstood me correctly.
But suggested solution doesn't work.
What I did:
pn_messenger_t* messenger = pn_messenger();
pn_messenger_start(messenger);
pn_messenger_subscribe(_pm.messenger, someaddress);
pn_messenger_set _timeout(messenger, 1000);
int _getcount = messages_count_to_receive;
int _gotcount = 0;
while (_gotcount _getcount)
{
pn_messenger_recv(messenger, _getcount - _gotcount);
//this line checks if nothing was received (maybe messages have
ended)
// Again, I get only 1 message. If I comment this line the
program enters
// an infinite loop but my queue are full of messages.
// IS IT CORRECT BEHAVIOUR?
if (_gotcount == pn_messenger_incoming(messenger))
break;
_gotcount = pn_messenger_incoming(messenger);
}
--
View this message in context:
http://qpid.2158936.n2.nabble.com/Receiving-messages-with-PROTON-messenger-tp7593934p7593949.html
Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
Receiving messages with PROTON messenger
Hello all. I am using proton to work with qpid and activemq. Send and receive
examples helped me to understand how I should work with messenger. But the
problem is in receiving messages and I wonder does it only my problem or a
common bug?
The common template of receive code, that was described in example looks
like:
pn_messenger_recv(messenger, MAXCOUNT);
check(messenger);
while(pn_messenger_incoming(messenger))
{
pn_messenger_get(messenger, message);
check(messenger);
...
}
While testing this code with activemq and qpid I found out that number of
received messages always equal to 1, regardless of MAXCOUNT value. Whatever
value I provide - I always receive only one message. Even proton example
uses the infinite loop (for (;;)) to get all messages from queue.
Does anybody can explain: is it a bug or my misunderstanding? What should I
do to receive N messages with pn_messenger_recv method over one call?
Thanks in advance.
--
View this message in context:
http://qpid.2158936.n2.nabble.com/Receiving-messages-with-PROTON-messenger-tp7593934.html
Sent from the Apache Qpid Proton mailing list archive at Nabble.com.
