activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sławomir Siudek (JIRA) <jira+amq...@apache.org>
Subject [jira] [Updated] (AMQNET-334) Sending a message to a nonexistent queue suspends the current thread.
Date Wed, 06 Jul 2011 07:34:16 GMT

     [ https://issues.apache.org/jira/browse/AMQNET-334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Sławomir Siudek updated AMQNET-334:
-----------------------------------

          Description: 
Code to reproduce:


    class Program
    {
        static void Main()
        {
            var factory = new ConnectionFactory(ConnectionFactory.DEFAULT_BROKER_URL);
            

            // This connection represents a client connection. 'clientResponseChannel' represents
'response' channel in request-response scenario.
            // The client closes connection before response will be delivered.
            IDestination clientResponseChannel = null;
            using (var clientConnection = factory.CreateConnection())
            using (var session = clientConnection.CreateSession())
            {
                clientConnection.Start();
                clientResponseChannel = session.CreateTemporaryTopic();
            }

            // This connection represents a service connection. The service tries send a message
to the client
            using (var con = factory.CreateConnection())
            using (var session = con.CreateSession())
            {
                con.Start();
                var producer = session.CreateProducer(clientResponseChannel);
                var msg = producer.CreateTextMessage("1"); // This line generates an exception
on ActiveMQ log.
                producer.Send(msg); // This line suspends current thread, or - sometimes -
invokes JMSException.
            }
        }
    }

    Affects Version/s: 1.5.1

> Sending a message to a nonexistent queue suspends the current thread.
> ---------------------------------------------------------------------
>
>                 Key: AMQNET-334
>                 URL: https://issues.apache.org/jira/browse/AMQNET-334
>             Project: ActiveMQ .Net
>          Issue Type: Bug
>          Components: NMS
>    Affects Versions: 1.5.1
>            Reporter: Sławomir Siudek
>            Assignee: Jim Gomes
>            Priority: Blocker
>
> Code to reproduce:
>     class Program
>     {
>         static void Main()
>         {
>             var factory = new ConnectionFactory(ConnectionFactory.DEFAULT_BROKER_URL);
>             
>             // This connection represents a client connection. 'clientResponseChannel'
represents 'response' channel in request-response scenario.
>             // The client closes connection before response will be delivered.
>             IDestination clientResponseChannel = null;
>             using (var clientConnection = factory.CreateConnection())
>             using (var session = clientConnection.CreateSession())
>             {
>                 clientConnection.Start();
>                 clientResponseChannel = session.CreateTemporaryTopic();
>             }
>             // This connection represents a service connection. The service tries send
a message to the client
>             using (var con = factory.CreateConnection())
>             using (var session = con.CreateSession())
>             {
>                 con.Start();
>                 var producer = session.CreateProducer(clientResponseChannel);
>                 var msg = producer.CreateTextMessage("1"); // This line generates an
exception on ActiveMQ log.
>                 producer.Send(msg); // This line suspends current thread, or - sometimes
- invokes JMSException.
>             }
>         }
>     }

--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira

       

Mime
View raw message