Re: Behavior when a message expires while it is processing

To get the JUnit test to pass, I created a BrokerFilter that will filter out duplicate messages based on the String property myMessageId. testJMSExpirationWithFilterPlugin.zip The behavior now is that o

Re: Behavior when a message expires while it is processing

So I ran testJMSExpirationAsn1 and got the following NPE. java.lang.NullPointerException at com.test.TestJMSExpirationNoCamel$DLQEndQueueConsumer.run(TestJMSExpirationNoCamel.java:188) at java.lang.Thread.run(Thread.java:722) I changed consumer.receive(3000) to consumer.receive(9000

Re: Behavior when a message expires while it is processing

The impact of having more than 1 message in the DLQ is that the process that reads from the DLQ will need to keep track of which messages it has processed. This introduces state and since there could be multiple processes reading from the DLQ the state would have to be shared. We are trying to avoi

Re: Behavior when a message expires while it is processing

I think what you are saying is correct from the broker's perspective. I tried coding up an example without using camel and I do not see the same behavior. The example can be found here http://s000.tinyupload.com/?file_id=62097383795604422204 I am not sure sure I coded up the example correctly.

Behavior when a message expires while it is processing

Hi, I am trying to understand the behavior when a message expires while it is being processed. I have the following flow setup in my test program. queue.start -> sleepProcessor -> queue.end The sleepProcessor takes the message from queue.start and sleeps for 5 seconds. I send a message to queue.