Mailing-List: contact users-help@qpid.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@qpid.apache.org
Message-ID: <DUB112-W754A9C24EB4B4FE8803183CD130@phx.gbl>
Content-Type: multipart/alternative;
	boundary="_201443d3-8d3c-4a06-9b45-1a752f31c226_"
From: Adel Boutros <adelboutros@live.com>
To: "users@qpid.apache.org" <users@qpid.apache.org>
Subject: [qpdi-dispatch 0.6.0] No delivery settled or accepted when using
 proton-c 0.12.2
Date: Tue, 16 Aug 2016 16:42:42 +0200
Importance: Normal
MIME-Version: 1.0
archived-at: Tue, 16 Aug 2016 14:42:56 -0000

--_201443d3-8d3c-4a06-9b45-1a752f31c226_
Content-Type: text/plain; charset="iso-8859-1"
Content-Transfer-Encoding: quoted-printable

Hello=2C

It seems that when a proton::container connects to a broker to send message=
=2C 2 callbacks are called after the on_sendable sends a message "on_delive=
ry_accept" and on_delivery_settle".

When my container connects to the dispatch router which is in its turn conn=
ected to a broker=2C I receive none of those. Although I can see my message=
 on the broker. Is this a known bug? Is it fixed with 0.6.1 version of the =
dispatch router?=20

I activated the PN_TRACE_FRM=3D1 on the client-side and noticed that in the=
 case of the dispatch router=2C I do not receive the following lines:

[000000000080FC10]:0 <- @disposition(21) [role=3Dtrue=2C first=3D0=2C last=
=3D0=2C settled=3Dtrue=2C state=3D@accepted(36) []]
[000000000080FC10]:0 <- @detach(22) [handle=3D0=2C closed=3Dtrue]

Regards=2C
Adel

=3D=3D=3D=3D=3D=3D
Code
=3D=3D=3D=3D=3D=3D
class MyHandler : public proton::handler
{

   void on_start(proton::event &e)
   {
      std::cout <<"on_start"<<std::endl=3B
      proton::url m_url("MACHINE:10454")=3B
      proton::connection conn =3D e.container().connect(m_url)=3B
      conn.open_sender("perf.topic")=3B
   }

   void on_sendable(proton::event &e)
   {
      std::cout <<"on_sendable"<<std::endl=3B
      proton::sender sender =3D e.sender()=3B
      proton::message m("Hello toto!")=3B
      sender.send(m)=3B
      sender.close()=3B
      e.connection().close()=3B
   }

   /// The remote peer accepted an outgoing message.
   void on_delivery_accept(proton::event &e)
   {
      std::cout <<"on_delivery_accept"<<std::endl=3B
   }
   /// The remote peer rejected an outgoing message.
   void on_delivery_reject(proton::event &e)
   {
      std::cout <<"on_delivery_reject"<<std::endl=3B
   }
   /// The remote peer released an outgoing message.
   void on_delivery_release(proton::event &e)
   {
      std::cout <<"on_delivery_release"<<std::endl=3B
   }
   /// The remote peer settled an outgoing message.
   void on_delivery_settle(proton::event &e)
   {
      std::cout <<"on_delivery_settle"<<std::endl=3B
   }

   void on_unhandled_error(proton::event &e=2C const proton::condition &c)
   {
      std::cout<<e.name()<<":" <<c.str() << std::endl=3B
   }

   void on_transport_error(proton::event &e)
   {
      std::cout<<"on_transport_error: " << e.transport().condition().str() =
<<std::endl=3B
   }
}=3B

=3D=3D=3D=3D=3D=3D=3D=3D=3D
BROKER (PN_TRACE_FRM=3D1 client-side)
=3D=3D=3D=3D=3D=3D=3D=3D
on_start
[000000000080FC10]:  -> AMQP
[000000000080FC10]:0 -> @open(16) [container-id=3D"092b8863-a51c-445b-846c-=
896f49238f6c"=2C hostname=3D"MACHINE:10455"=2C channel-max=3D32767]
[000000000080FC10]:0 -> @begin(17) [next-outgoing-id=3D0=2C incoming-window=
=3D2147483647=2C outgoing-window=3D2147483647]
[000000000080FC10]:0 -> @attach(18) [name=3D"1/1"=2C handle=3D0=2C role=3Df=
alse=2C snd-settle-mode=3D2=2C rcv-settle-mode=3D0=2C source=3D@source(40) =
[durable=3D0=2C timeout=3D0=2C dynamic=3Dfalse]=2C target=3D@targe
t(41) [address=3D"perf.topic"=2C durable=3D0=2C timeout=3D0=2C dynamic=3Dfa=
lse]=2C initial-delivery-count=3D0]
[000000000080FC10]:  <- AMQP
[000000000080FC10]:0 <- @open(16) [container-id=3D"5c480e45-a289-4c16-947b-=
f352419370af"=2C max-frame-size=3D32768=2C channel-max=3D255=2C idle-time-o=
ut=3D0=2C properties=3D{:product=3D"qpid"=2C :versio
n=3D"6.0.1"=2C :"qpid.build"=3D"1731621"=2C :"qpid.instance_name"=3D"Broker=
"}]
[000000000080FC10]:0 <- @begin(17) [remote-channel=3D0=2C next-outgoing-id=
=3D0=2C incoming-window=3D2048=2C outgoing-window=3D2048]
[000000000080FC10]:0 <- @attach(18) [name=3D"1/1"=2C handle=3D0=2C role=3Dt=
rue=2C snd-settle-mode=3D2=2C rcv-settle-mode=3D0=2C source=3D@source(40) [=
durable=3D0=2C timeout=3D0=2C dynamic=3Dfalse]=2C target=3D@target
(41) [address=3D"perf.topic"=2C durable=3D0=2C timeout=3D0=2C dynamic=3Dfal=
se]]
[000000000080FC10]:0 <- @flow(19) [next-incoming-id=3D0=2C incoming-window=
=3D2048=2C next-outgoing-id=3D0=2C outgoing-window=3D2048=2C handle=3D0=2C =
delivery-count=3D0=2C link-credit=3D20000=2C echo=3Dfalse]
on_sendable
[000000000080FC10]:0 -> @transfer(20) [handle=3D0=2C delivery-id=3D0=2C del=
ivery-tag=3Db"\x01\x00\x00\x00\x00\x00\x00\x00"=2C message-format=3D0=2C se=
ttled=3Dfalse=2C more=3Dfalse] (148) "\x00Sp\xd0\x00
\x00\x00\x0b\x00\x00\x00\x05BP\x04@BR\x00\x00Ss\xd0\x00\x00\x00-\x00\x00\x0=
0\x0d@@@\xa1\x0atest@@@@\x83\x00\x00\x00\x00\x00\x00\x00\x00\x83\x00\x00\x0=
0\x00\x00\x00\x00\x00@R\
x00@\x00St\xd1\x00\x00\x004\x00\x00\x00\x04\xa1\x0ctest\xa1\x02test\xa1\x11=
test\xa1\x09test\x00Sw\xa1\x0bHello toto!"
[000000000080FC10]:0 -> @detach(22) [handle=3D0=2C closed=3Dtrue]
[000000000080FC10]:0 -> @close(24) []
on_sendable
[000000000080FC10]:  -> EOS
[000000000080FC10]:0 <- @disposition(21) [role=3Dtrue=2C first=3D0=2C last=
=3D0=2C settled=3Dtrue=2C state=3D@accepted(36) []]
[000000000080FC10]:0 <- @detach(22) [handle=3D0=2C closed=3Dtrue]
[000000000080FC10]:0 <- @close(24) []
[000000000080FC10]:  <- EOS
on_delivery_accept
on_delivery_settle

=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D
DISPATCH ROUTER  (PN_TRACE_FRM=3D1 client-side)
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D
on_start
[000000000068FC10]:  -> AMQP
[000000000068FC10]:0 -> @open(16) [container-id=3D"915e8a02-4056-4c60-ab27-=
18068462d862"=2C hostname=3D"MACHINE:10454"=2C channel-max=3D32767]
[000000000068FC10]:0 -> @begin(17) [next-outgoing-id=3D0=2C incoming-window=
=3D2147483647=2C outgoing-window=3D2147483647]
[000000000068FC10]:0 -> @attach(18) [name=3D"1/1"=2C handle=3D0=2C role=3Df=
alse=2C snd-settle-mode=3D2=2C rcv-settle-mode=3D0=2C source=3D@source(40) =
[durable=3D0=2C timeout=3D0=2C dynamic=3Dfalse]=2C target=3D@targe
t(41) [address=3D"perf.topic"=2C durable=3D0=2C timeout=3D0=2C dynamic=3Dfa=
lse]=2C initial-delivery-count=3D0]
[000000000068FC10]:  <- AMQP
[000000000068FC10]:0 <- @open(16) [container-id=3D"router.10454"=2C max-fra=
me-size=3D16384=2C channel-max=3D32767=2C idle-time-out=3D8000=2C offered-c=
apabilities=3D:"ANONYMOUS-RELAY"=2C properties=3D{:p
roduct=3D"qpid-dispatch-router"=2C :version=3D"0.6.0"}]
[000000000068FC10]:0 <- @begin(17) [remote-channel=3D0=2C next-outgoing-id=
=3D0=2C incoming-window=3D61=2C outgoing-window=3D2147483647]
[000000000068FC10]:0 <- @attach(18) [name=3D"1/1"=2C handle=3D0=2C role=3Dt=
rue=2C snd-settle-mode=3D2=2C rcv-settle-mode=3D0=2C source=3D@source(40) [=
durable=3D0=2C timeout=3D0=2C dynamic=3Dfalse]=2C target=3D@target
(41) [address=3D"perf.topic"=2C durable=3D0=2C timeout=3D0=2C dynamic=3Dfal=
se]=2C initial-delivery-count=3D0]
[000000000068FC10]:0 <- @flow(19) [next-incoming-id=3D0=2C incoming-window=
=3D61=2C next-outgoing-id=3D0=2C outgoing-window=3D2147483647=2C handle=3D0=
=2C delivery-count=3D0=2C link-credit=3D250=2C drain=3Dfalse]

on_sendable
[000000000068FC10]:0 -> @transfer(20) [handle=3D0=2C delivery-id=3D0=2C del=
ivery-tag=3Db"\x01\x00\x00\x00\x00\x00\x00\x00"=2C message-format=3D0=2C se=
ttled=3Dfalse=2C more=3Dfalse] (148) "\x00Sp\xd0\x00
\x00\x00\x0b\x00\x00\x00\x05BP\x04@BR\x00\x00Ss\xd0\x00\x00\x00-\x00\x00\x0=
0\x0d@@@\xa1\x0atest@@@@\x83\x00\x00\x00\x00\x00\x00\x00\x00\x83\x00\x00\x0=
0\x00\x00\x00\x00\x00@R\
x00@\x00St\xd1\x00\x00\x004\x00\x00\x00\x04\xa1\x0ctest\xa1\x02test\xa1\x11=
test\xa1\x09test\x00Sw\xa1\x0bHello toto!"
[000000000068FC10]:0 -> @detach(22) [handle=3D0=2C closed=3Dtrue]
[000000000068FC10]:0 -> @close(24) []
on_sendable
[000000000068FC10]:  -> EOS
[000000000068FC10]:0 <- @close(24) []
[000000000068FC10]:  <- EOS

 		 	   		  =

--_201443d3-8d3c-4a06-9b45-1a752f31c226_--