[
https://issues.apache.org/jira/browse/AMQNET-485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14096068#comment-14096068
]
Timothy Bish commented on AMQNET-485:
-------------------------------------
Attempted to reproduce with no luck:
{code}
[Test]
public void TestDelayInReceiveDoesntLoseMessagesAsync()
{
using (IConnection connection = CreateConnection(TEST_CLIENT_ID))
{
using (ISession session =
connection.CreateSession(AcknowledgementMode.AutoAcknowledge))
{
IDestination destination = session.CreateTemporaryQueue();
using (IMessageProducer producer =
session.CreateProducer(destination))
{
for (int i = 0; i < 10; ++i)
{
ITextMessage message =
session.CreateTextMessage("test");
producer.Send(message);
}
}
IMessageConsumer consumer =
session.CreateConsumer(destination);
consumer.Listener += OnAsyncMessageDispatch;
connection.Start();
Thread.Sleep(2000);
Assert.IsTrue(doneLatch.await(TimeSpan.FromSeconds(10)));
}
}
}
private void OnAsyncMessageDispatch(IMessage msg)
{
counter++;
doneLatch.countDown();
}
{code}
> Messages are being marked as duplicate in error
> -----------------------------------------------
>
> Key: AMQNET-485
> URL: https://issues.apache.org/jira/browse/AMQNET-485
> Project: ActiveMQ .Net
> Issue Type: Bug
> Affects Versions: 1.6.3
> Reporter: Murali Mogalayapalli
> Assignee: Jim Gomes
>
> Messages are being marked as a duplicate in error and are being discarded.
> This happens to all the messages that are delivered to MessageConsumer before
> a listener is setup on the MessageConsumer
--
This message was sent by Atlassian JIRA
(v6.2#6252)
