Re: Nack a message in Artemis core API

2019-05-22 Thread Justin Bertram
If you want to reject a message then when you create your consumer make sure you set autoCommitAcks to false and then if you want to reject a message invoke org.apache.activemq.artemis.api.core.client.ClientSession#rollback(). See this test-case [1] for an example. Justin [1] https://github.com/

Re: Needing header to trace lost messages

2019-05-22 Thread Timothy Bish
On 5/22/19 1:10 PM, leejacks...@cox.net wrote: Our header is a string value, so we tried using cms_getMessageStringProperty(txtMessage, "OriginalDestination", key, bufferLen). It is failing with a return code of 1. Any ideas? -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-Use

Re: Needing header to trace lost messages

2019-05-22 Thread leejacks...@cox.net
Our header is a string value, so we tried using cms_getMessageStringProperty(txtMessage, "OriginalDestination", key, bufferLen). It is failing with a return code of 1. Any ideas? -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html

Needing header to trace lost messages

2019-05-22 Thread leejacks...@cox.net
We have a consumer to pull messages off broker. The messages are sent to a JMS Gateway and then a broker. We have messages being lost. We have been asked by the JMS Gateway team to add a header in our consumer log in addition to the message. I have looked over the consumer code give by Apache

Re: Needing header to trace lost messages

2019-05-22 Thread Timothy Bish
On 5/22/19 11:25 AM, leejacks...@cox.net wrote: Hi! We have a consumer written using the cms_browserGetNextMessages function written by Apache (https://github.com/fusesource/fusemq-c/blob/master/fusemqc-client/src/main/cpp/CMS_QueueBrowser.cpp). We are experiencing missing messages. We post mes

Needing header to trace lost messages

2019-05-22 Thread leejacks...@cox.net
Hi! We have a consumer written using the cms_browserGetNextMessages function written by Apache (https://github.com/fusesource/fusemq-c/blob/master/fusemqc-client/src/main/cpp/CMS_QueueBrowser.cpp). We are experiencing missing messages. We post messages to a JMS Gateway. The Gateway sends to a