activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Timothy Bish (JIRA)" <jira+amq...@apache.org>
Subject [jira] [Commented] (AMQNET-485) Messages are being marked as duplicate in error
Date Wed, 13 Aug 2014 20:32:12 GMT

    [ 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)

Mime
View raw message