You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@activemq.apache.org by "Sławomir Siudek (JIRA)" <ji...@apache.org> on 2011/07/06 09:30:16 UTC

[jira] [Created] (AMQNET-334) Sending a message to a nonexistent queue suspends the current thread.

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
            Reporter: Sławomir Siudek
            Assignee: Jim Gomes
            Priority: Blocker
             Fix For: 1.5.2




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

       

[jira] [Updated] (AMQNET-334) Sending a message to a nonexistent queue suspends the current thread.

Posted by "Sławomir Siudek (JIRA)" <ji...@apache.org>.
     [ 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

       

[jira] [Resolved] (AMQNET-334) Sending a message to a nonexistent queue suspends the current thread.

Posted by "Timothy Bish (JIRA)" <ji...@apache.org>.
     [ https://issues.apache.org/jira/browse/AMQNET-334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Timothy Bish resolved AMQNET-334.
---------------------------------

       Resolution: Fixed
    Fix Version/s: 1.6.0
                   1.5.2

Added support for monitoring the advisories for temp destinations being added and removed so the client can error out when you use one incorrectly.

> 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: Timothy Bish
>            Priority: Blocker
>             Fix For: 1.5.2, 1.6.0
>
>
> 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

       

[jira] [Commented] (AMQNET-334) Sending a message to a nonexistent queue suspends the current thread.

Posted by "Timothy Bish (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/jira/browse/AMQNET-334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13060558#comment-13060558 ] 

Timothy Bish commented on AMQNET-334:
-------------------------------------

One issue here is that NMS.ActiveMQ doesn't currently listen for advisories so it doesn't know which destinations have been deleted.  There have also been a couple of recent fixes in trunk for ActiveMQ related to removing and re-adding a destination that could also have an affect on this case.  

> 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

       

[jira] [Commented] (AMQNET-334) Sending a message to a nonexistent queue suspends the current thread.

Posted by "Timothy Bish (JIRA)" <ji...@apache.org>.
    [ https://issues.apache.org/jira/browse/AMQNET-334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13061623#comment-13061623 ] 

Timothy Bish commented on AMQNET-334:
-------------------------------------

I've implemented most of the Temp Destination monitoring for NMS.ActiveMQ, should be able to backport to v1.5.x branch for a v1.5.2 release at some point.

> 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: Timothy Bish
>            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

       

[jira] [Updated] (AMQNET-334) Sending a message to a nonexistent queue suspends the current thread.

Posted by "Sławomir Siudek (JIRA)" <ji...@apache.org>.
     [ https://issues.apache.org/jira/browse/AMQNET-334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

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

    Fix Version/s:     (was: 1.5.2)

> 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
>            Reporter: Sławomir Siudek
>            Assignee: Jim Gomes
>            Priority: Blocker
>


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

       

[jira] [Assigned] (AMQNET-334) Sending a message to a nonexistent queue suspends the current thread.

Posted by "Timothy Bish (JIRA)" <ji...@apache.org>.
     [ https://issues.apache.org/jira/browse/AMQNET-334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Timothy Bish reassigned AMQNET-334:
-----------------------------------

    Assignee: Timothy Bish  (was: Jim Gomes)

> 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: Timothy Bish
>            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