[ 
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


Reply via email to