activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Palm Kevin (JIRA)" <jira+amq...@apache.org>
Subject [jira] Commented: (AMQNET-213) selector not working anymore
Date Wed, 25 Nov 2009 13:09:52 GMT

    [ https://issues.apache.org/activemq/browse/AMQNET-213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=56095#action_56095
] 

Palm Kevin commented on AMQNET-213:
-----------------------------------

The problem seems even be more basic: Message receiption from queue not working any more:
{quote}
Public Sub ProduceConsumeMessageTest()
        Using connection As IConnection = New ActiveMQ.ConnectionFactory("tcp:\\localhost:61616").CreateConnection()
            Using session As ISession = connection.CreateSession(AcknowledgementMode.AutoAcknowledge)
                ' Delete queue in order to ensure it is empty
                session.DeleteDestination(session.GetQueue("TestQueue"))

                Dim prod As IMessageProducer = session.CreateProducer(session.GetQueue("TestQueue"))
                Dim msg As ITextMessage = prod.CreateTextMessage()
                msg.Text = "abc"
                prod.Send(msg, MsgDeliveryMode.Persistent, MsgPriority.Normal, TimeSpan.MinValue)
                prod.Close()

                Dim consumer = session.CreateConsumer(session.GetQueue("TestQueue"))
                Dim fetchedMessage = consumer.Receive(TimeSpan.FromMilliseconds(10000))
                Assert.IsNotNull(fetchedMessage)
                Assert.AreEqual("abc", CType(fetchedMessage, ITextMessage).Text)
                consumer.Close()
            End Using
        End Using
    End Sub
{quote}
I never get the fetched message !?
(I just executed exactly the same test with NMS 1.1.0 and it works... but not with Trunk)

> selector not working anymore
> ----------------------------
>
>                 Key: AMQNET-213
>                 URL: https://issues.apache.org/activemq/browse/AMQNET-213
>             Project: ActiveMQ .Net
>          Issue Type: Bug
>          Components: ActiveMQ
>    Affects Versions: 1.2.0
>            Reporter: Palm Kevin
>            Assignee: Jim Gomes
>
> When I try to commit a message (which connection and session already has been closed),
then previously I executed this code:
> {quote}
>     Public Sub Commit(ByVal message As IMessage)
>             Using connection As IConnection = Me.CreateIncomingConnection()
>                 Using session As ISession = connection.CreateSession(AcknowledgementMode.AutoAcknowledge)
>                     Dim consumer = session.CreateConsumer(message.NMSDestination, "NMSMessageID='"
+ message.NMSMessageId + "'")
>                     Dim fetchedMessage = consumer.Receive(TimeSpan.FromMilliseconds(100))
>                     If fetchedMessage Is Nothing Then _
>                         Throw New Exception("Unable to commit message: cannot find message
with id '" + message.NMSMessageId + "'")
>                     consumer.Close()
>                 End Using
>             End Using
>     End Sub
> {quote}
> Now, my code always throws the exception because the searched message cannot be found!
> This code is *working with release 1.1.0*. but it *doens't work with Trunk*

-- 
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.


Mime
View raw message