I'm actually just using the sample code from that package, but linking it against qpid-proton 0.7.
On the other hand, I just went to look at all of it again and I mistyped the binding. *sigh* All is well now, I can receive the messages across to the correct queue and with the correct subject. Sorry for the noise. On Fri, Oct 17, 2014 at 9:35 AM, Ted Ross <[email protected]> wrote: > > > On 10/17/2014 12:13 PM, Tim Wojtulewicz wrote: > > We have some code written using the normal qpid C++ messaging API in > > qpid-0.26 that opens a receiver using an address that creates a queue on > > the fly. This queue includes x-bindings to only receive messages that > have > > the subject set to match. It then sits and listens for messages to be > > received on that queue. We have some other code that opens a sender and > > posts messages directly to the amq.topic exchange. Since the queues are > > created on the topic exchange, the messages are filtered and delivered to > > the queues that have their x-bindings set correctly. > > > > Receiver: > > > > qpid::messaging::Address addr("test_queue; {create: always, delete: > > receiver, mode: consume, node: {type: queue, x-declare: {auto-delete: > > true}}, link: {x-declare: {arguments: {no-local: true}}, > > x-bindings:[{exchange: 'amq.topic', queue: 'test_queue', key: > > '129.1.10.2'}],}}"; > > qpid::messaging::Receiver recv = session.createReceiver(addr); > > > > Sender: > > > > qpid::messaging::Sender sender = session.createSender("amq.topic"); > > qpid::messaging::Message msg; > > msg.setSubject("129.1.10.2"); > > msg.setContent("test"); > > sender.send(msg); > > > > I recently started working on some Android code and instead of > reinventing > > the wheel and writing a bridge to connect our current qpid code to > Android, > > I found a fork of qpid-proton that supports Android ( > > https://github.com/AppPlatPerf/qpid-proton/tree/AndroidProton/proton-a) > > Instead of going write into integrating this into my Android code, I > > decided to run a quick test program using proton-c to see if I could > > actually get it to work with the C API. > > > > And here's where I have problems. > > > > I created a queue manually using qpid-config including adding some > bindings > > to it. Then using the example code in that github repo (see > > > https://github.com/AppPlatPerf/qpid-proton/tree/AndroidProton/examples/messenger/c > ) > > and attached the receiver to the queue. Using a separate program I sent a > > message directly to the amq.topic exchange with the subject set to match > > the binding. The message was never received. Is there something that that > > example isn't doing that I need to do to receive these messages? Am I > doing > > it wrong by using queues? What am I missing? > > I don't see why this shouldn't work. Can you confirm with qpid-stat > that the message was delivered to the queue? Have you tried it with the > current Proton (not the forked one)? > > > Thanks, > > > > Tim > > > > --------------------------------------------------------------------- > To unsubscribe, e-mail: [email protected] > For additional commands, e-mail: [email protected] > >
