Thank you very much Tony, using pn_messenger_set_outgoing_window() with a size of 1 actually solved our problem.
On Wednesday 18 March 2015 23:40:09 Tony Ercolano wrote: > This article might help you. Take special note of peeklock and > receiveanddelete mode. > > http://blogs.msdn.com/b/servicebus/archive/2014/12/16/using-service-bus-with > -the-proton-c-client.aspx > > -----Original Message----- > From: Jorge Sáez Gómez [mailto:[email protected]] > Sent: Wednesday, March 18, 2015 3:28 AM > To: [email protected] > Subject: Messages not deleted from queue > > Hello everyone, > > I'm using qpid on C++ to receive messages from a remote Azure Service Bus. > I'm capable of getting all incoming messages, but don't get removed from the > queue. As I result, I keep getting them continuously. This is the code I'm > running, which gets executed inside a larger, infinite loop: > > void cloudRecv(const char* address, char* buffer, size_t buffer_length) { > pn_messenger_t* messenger = pn_messenger(NULL); > > pn_messenger_start(messenger); > check(messenger); > > pn_messenger_subscribe(messenger, address); > check(messenger); > > pn_message_t* message = pn_message(); > > pn_messenger_recv(messenger, 1); > check(messenger); > > pn_messenger_incoming(messenger); > > pn_messenger_get(messenger, message); > check(messenger); > > pn_data_t *body = pn_message_body(message); > > pn_data_format(body, buffer, &buffer_length); > > pn_tracker_t tracker = pn_messenger_incoming_tracker(messenger); > > pn_message_free(message); > > pn_messenger_stop(messenger); > pn_messenger_free(messenger); > } > > I actually need to re-create a fresh messenger at every iteration since, if > I don't, when my code has processed all messages within the queue, it > detaches from the queue and blocks the thread until the connection times > out. I have been experimenting with the following functions, without any > success so far: > > pn_messenger_set_rcv_settle_mode() > pn_messenger_accept() > pn_messenger_settle() > > I'm already pretty much out of ideas. Any help would be appreciated. Thank > you all in advance. > > Regards, > > Jorge. > > --------------------------------------------------------------------- > To unsubscribe, e-mail: [email protected] For additional > commands, e-mail: [email protected] > > > --------------------------------------------------------------------- > To unsubscribe, e-mail: [email protected] > For additional commands, e-mail: [email protected] -- -----BEGIN PGP PUBLIC KEY BLOCK----- Version: GnuPG v2.0.22 (GNU/Linux) mQINBFQDBt8BEAC4Rg4NFG8/x17JvvDmM4XlFI+EH29sLGXz7DrfDNAKHwgDb2mo V4RsZmyt0keGCjkl3RvHxcLlAxRJne/R3wU0FkQzlwhPu7T2yJSWdbA+PAMGXvFe vjk8Zbwtmoqh5LbVsUpWn0BoaSgZtGZL42ftAD9Nuz3k/rtfZ4z69hGwyiTtTc16 Bcmc6m3CO4xE359o/gU0ytX89v4S7aGYsTEHBXOvb7WK/LqNeWzuVm339nFJCM2T udNfVFrQ30kiUdfOVR0U11umFJDZKzt8Lnou8k2ADGd4Xr4PoO4AlNKcCL+xAMkx /Gj0FTZADslWIr3fKNAarJQPlR4swwKmS8+wRzJ/i94SnrX0HQNZZ59sKx4AHrN+ abra4ZuHBA2ze+8hN4xUd7jMqQClW33nVfPfWDrh8eSYG34kxEw9NxgVgE4K3sr8 5IaW/6StICm0Zncy4Pt2IAUSWX8T3mBOpoMmCceeb/OoUJh7gwYU65ZV4CwAFlEY v/sGk3Euf41CbViqCpYxcZBV+uFNzj9ITuVj0WK3bH6dkGCgG+Qvht6l2lLq/c1E JLItBfYsp7NWv8yrkLMQPG+1f5lIzZGZKqDa0jbJWYOvfE3xc/wyFmkCYBD8YKof LgBRYRrLsokPyBJTE8gZ9vYlLrLPYGMllDdcAskFYckrPVIKMxkjtl0t8wARAQAB tCVKb3JnZSBTw6FleiBHw7NtZXogPGpvc2Fnb0BnbWFpbC5jb20+iQI4BBMBAgAi BQJUAwbfAhsDBgsJCAcDAgYVCAIJCgsEFgIDAQIeAQIXgAAKCRAACWMzmQq2llfd D/0cjzlATFDhwk6kN3q/v+8yfP+K0qXH6qFAJLLjO0TJEGfVOebgKCz0+cPwzuq9 tp2U2gclNA+x14xWNHA+7nY0xlDVb8Y17P3yvmufcJv7gLHapZR2PJPGg3wvi4or G8pCwLxlBgjkdJdY4wJQRfW9k6EO4rmrOUz1bvMKmGqJqHObRQ1httwYsHDDSozp 7dOG2sSXIMfQtJmXOaxWR5gu06pstlB01FZOyPYUdaw2tkvhfQIdVNDvwt2T5TUY ha+PYP7e8sMuMBM+QzEIDmgvna3S4yfcvYjC/z3Rhqfpwahax+hGq+SDctJw1yW0 9N6es3IyZZ46WjvIJPhFboD9N9q0DnwB/JHwHx2Uz9CrY9peR/R8G9UeqeZZ8kEf WgfOKDl+g2lTsymkIqn09ixqkn6VXsk21aMH8x1wl5T/6upGO60K7M6HrzFvFxi8 HUtlTJOrzCI7Imsy9Z+K+iGk/jJvWPOOpS3/cumnddFteEYJfMNnZq5ueZksw+Uz A6sZI2wfI130OPmO/0WWlyOCTRIaB/Vw/tPncnys9sIOIjScex3+TOjT4Cy4OxX2 3w9URKRrIYGUCX7dP6gpxdz6LFgE6En39GO5We8lDQM8IdGB+LkIQhyDRdbec4bE HXGvFSulErDAx4g+f3rKe1uBlby6MggzHXf/hGqzwGibWLkCDQRUAwbfARAAwEVq nd3opv1jmUurrL+29bM09WXfHHV77N8Lqh+nRjrK0irN5uZEvyP74vKqEkYkNW1B fzJmGkv57VGtWfW1Yd6DDBx75gvwCitX+ebVnn1A5fTWnBAav7/sZk75v5JqfAo+ jl5Jgg8e9lRjkYu2LVdCEZzYqeqtMBN0ugtKRIa6cGte7ji5PBvESu+PkJWDi9K4 YhAcmAgEkYp/20jty0HhhYiO1PrRaL61srciVjY3/cp6OKGstQJBmkWYWFjm37GG 3cfOV7nhxe3eY4DIG/6G8+Hs3VUAfNXK5YK7TYqbK8OzlTL0VtqCmhk36mKzn2Rp 5adxVSkcfX2J0MCSz18f+xiON6jfZp4MCfBkr7t/HgEebr4ilV26JaIYfETqOBHg qaqJl9Pw/f+XeRq1hqdtOJe9BNL5uGOcut1gSFLD5Yh/Ho6CbrRplgMZ3Gv2FZ6x 1meN8zCE2y9bjJaIzQgQx6oMWJH3FqOkoswtAHd5As8bEhuqeNvTmgU6XqWHpXoA gM/lbv0FcR+DQ3XoourNYnBfhm1557Bq2JU4Bt80aMZ5b91QnuZeCNeixId9VXRR uT7YZIMzdNv6U3zsuYNGCZjIEhet0bpAjzXrR5ZBj7Q3K0Z+YphaCSgZqinMHWiD nRQ0svsXYUUL00bkgLXkpm7B+j8kyNy6M/YIC1sAEQEAAYkCHwQYAQIACQUCVAMG 3wIbDAAKCRAACWMzmQq2lhO/D/4mue1r+UlLJIaPDNcEhxHYhY56mSXi3zhYFobD TWcktbWJeFWRRa28nxET54mFU82X+ofO7iezOYT7ib3U/s0hbA5R7/WyBpItGC9E 9Ml6BE7vz5ZhAOnBfnwkcC8nyl0dE7aYukpjbZMJpvqhY1BU0Sy0Jirc4x7oUBqh lPiHXjtutUVhqDKUwaZTqTPOBQjiVFAdIVahYHRLUYKDcQzQgSyLZI1USYSzsWb2 spoeLv45opcd/oUnWjudC0h31EoRHtOmJuyTRQb2s1PtygrmoM0gy4AvI78iMf+F 8UoJE4/9UFZ6KBTtuJaE/yin85Zv3luKLeREoqYirXZgDXSZtkft7pBb1qmwiPhY DQEcaeQnDV30EL4Jz48n1kfeBazfFaAgb51mi/4Oa78qhSRBAvxBpEX9qxLkmO8H smANwC+7zTukeMMJtcTplE+A9zb2pwWPZ91sXGndm8h5b/58QHUOqkphd7jvmpqU Pz15PvjEk+SUD5a/FZdVEPtnch7IhP8ljk9PApGDNGWFwSRE3weAau0cw79nt/ZJ tm4bvBFLenhDPCN0itBx5QuZ9i1LLNz8ai+qGeEfFd1YkPkHJRiVV2dR7CN61H4r sxU1wbLIjo3NFtCcOszAEtUWUpxaQe5l3Te1bjuPgYHDOpkMn0JYXFyhZFu76QeM IBGQFg== =fRxB -----END PGP PUBLIC KEY BLOCK----- --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
