Skip to content
Permalink
Browse files
Add Clone() override that will copy the MessagePropertyIntercepter ob…
…ject.

Fixes [AMQNET-292]. (See https://issues.apache.org/activemq/browse/AMQNET-292)
  • Loading branch information
Jim Gomes committed Nov 10, 2010
1 parent 8c33aa4 commit fcb9895d8e3b0ffd7229c66310713ee21cda69fd
Showing 1 changed file with 7 additions and 3 deletions.
@@ -161,7 +161,8 @@ protected void DelayedProducerThreadProc(Object arg)
public void TestDoChangeSentMessage(
[Values(AcknowledgementMode.AutoAcknowledge, AcknowledgementMode.ClientAcknowledge,
AcknowledgementMode.DupsOkAcknowledge, AcknowledgementMode.Transactional)]
AcknowledgementMode ackMode)
AcknowledgementMode ackMode,
[Values(true, false)] bool doClear)
{
using(IConnection connection = CreateConnection())
{
@@ -183,8 +184,11 @@ protected void DelayedProducerThreadProc(Object arg)

producer.Send(message);

message.ClearBody();
message.ClearProperties();
if(doClear)
{
message.ClearBody();
message.ClearProperties();
}
}

if(ackMode == AcknowledgementMode.Transactional)

0 comments on commit fcb9895

Please sign in to comment.