[
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
