Dear all,
I am writing as I am experiencing an issue with Qpid Proton and some
specific AMQP brokers.
In particular, I am currently using Qpid Proton 0.33.0 (the C++ version) in
a project. In order to set up the client, I based my code on the examples
available in the official documentation (like
w work to be added to the Qpid Proton thread
with "work_queue()->add([=]() { sender_.send(msg); });").
Thank you again for your assistance,
Francesco Raviglione
Il giorno gio 26 nov 2020 alle ore 16:00 Robbie Gemmell <
robbie.gemm...@gmail.com> ha scritto:
> I dont thi
afety?).
Thank you very much,
Francesco Raviglione
Il giorno mer 18 nov 2020 alle ore 11:25 Robbie Gemmell <
robbie.gemm...@gmail.com> ha scritto:
> On Tue, 17 Nov 2020 at 19:59, Francesco Raviglione
> wrote:
> >
> > Dear all,
> > I'm experiencing some issues
rsion of the library (I would prefer to stick with C++, in this case, and
not to fall back to Qpid Proton C).
Do you know how I can solve this problem? Is there a way to "inject"
external aperiodic events/data to be sent via AMQP?
Thank you very much in advance,
Francesco Raviglione
hen creating it (I believe by using None in Python) and then have
> each message specifically carry its destination address (I believe
> passing address= when creating the Message object in Python)
>
> Robbie
>
> On Fri, 17 Jul 2020 at 19:21, Francesco Raviglione
> wrote:
be best to just stick to the more regular, documented,
> maintained path and use the Container along with the EventInjector etc
> though.
>
> Robbie
>
> On Fri, 17 Jul 2020 at 10:47, Francesco Raviglione
> wrote:
> >
> > Dear Robbie,
> > Thank you very
at I just reported as
a reply to the other thread (
http://qpid.2158936.n2.nabble.com/Getting-local-idle-timeout-expired-on-blocking-connection-possible-bug-td7692985.html
).
Thank you very much again,
Francesco
Il giorno ven 17 lug 2020 alle ore 12:14 Robbie Gemmell <
robbie.gemm...@gmail.com&
d to the
> server will be half of this actual timeout to avoid spurious timeouts,
> i.e 1/2 sec in this case. If it's a proton[-j] based server it will
> also half the received value in case the sending peer had not done so,
> and so expect to send data or a heartbeat at 1/4 second period
(e.g. 1 second), I always get
this error.
Do you know why? Is it some sort of bug or is there something wrong in my
sample code?
Thank you very much,
Francesco Raviglione
cking of link credit
>
> resume proactor main event loop (proactor_done +
> proactor_wait) and handle events --> if FLOW event is seen --> yield
>
> }
>
> }
> Others may have better ideas, I am just beggining to use Proton-C.
>
> Hope this helps,
&g
that can
> read from a different source and then send the same message to an AMQP
> destination.
>
> It may seem hard in the beggining but once you get a hold on how to
> integrate proton events loop into your program loop, it has good chances to
> work.
>
> Adrian
>
>
> On
nnot manage properly the AMQP 1.0 connection (is this correct?).
How could I achieve the desired result? How can I make the loop wait for
external data and then immediately send it?
Thank you very much in advance,
Francesco Raviglione
Dear all,
I'm trying use the Python version of Qpid Proton to perform the following
task, together with a Tornado HTTP server:
1) The Tornado web application should listen to a certain port and wait for
POST requests
2) When a POST request occurs, it should get the received data (which is
divided
Dear all,
I tried starting the Qpid Proton C++ even loop inside a thread, created
with "pthread_create()", while experimenting with the library.
However, I'm always getting a non-working code, which often causes some
weird behavior.
In particular, I tried creating an example by modifying the
apache.org/releases/qpid-proton-0.30.0/proton/cpp/api/multithreaded_client_8cpp-example.html
> could be useful to look at.
>
> Robbie
>
> On Thu, 19 Mar 2020 at 18:48, Francesco Raviglione
> wrote:
> >
> > Dear all,
> > I am writing you because I'm trying to better
Dear all,
I am writing you because I'm trying to better understand how to use the
Qpid Proton C++ library, after learning a bit how to work with the C API.
My goal would be, in particular, to write a client/producer which can
connect to an external broker, from which other clients can then
8 Gordon Sim ha
scritto:
> On 10/02/2020 1:12 am, Chuck Rolke wrote:
> > ----- Original Message -
> >> From: "Francesco Raviglione"
> >> To: users@qpid.apache.org
> >> Sent: Saturday, February 8, 2020 5:36:39 AM
> >> Subject: Avo
Hello,
I'm sorry about the several questions I'm posting on the mailing list
during these days, but, unfortunately, I'm struggling a bit in the usage of
Qpid Proton (in particular, on the C version).
One issue I noticed, and that I was not able to solve, is related to the
fact that, when
ize);
amqp_bytes=pn_data_get_binary(pn_message_body(amqp_message));
.
Thanks!
Il giorno mer 5 feb 2020 alle ore 15:25 Francesco Raviglione <
francescorav.es...@gmail.com> ha scritto:
> Dear all,
> I am writing you because I'm working with the C Qpid Proton library.
> In particul
Dear all,
I am writing you because I'm working with the C Qpid Proton library.
In particular, I'm using as reference the "C API reference", available
here:
https://qpid.apache.org/releases/qpid-proton-0.30.0/proton/c/api/files.html
I'm able to successfully send AMQP messages carrying binary data,
Dear Gordon,
I am very sorry for the big delay in replying you.
Thank you very much for your reply and for the explanation.
Now everything is much clearer.
I will try running the equivalent of the run() loop in the two threads.
Thank you again for your assistance!
Dear all,
I am writing you beceause I am trying to use the Qpid Proton library to
create an AMQP client, written in C (thus using as a reference the "C API
reference":
https://qpid.apache.org/releases/qpid-proton-0.30.0/proton/c/api/files.html
).
This client should be able to concurrently receive
22 matches
Mail list logo
