SPRNET-1017 - Apache.NMS.ActiveMQ.ConnectionClosedException when using CachingConnectionFactory
This commit is contained in:
@@ -255,7 +255,7 @@ namespace Spring.Messaging.Nms.Connections
|
||||
{
|
||||
foreach (DictionaryEntry entry in cachedProducers)
|
||||
{
|
||||
((IMessageProducer)entry.Value).Dispose();
|
||||
((IMessageProducer)entry.Value).Close();
|
||||
}
|
||||
foreach (DictionaryEntry entry in cachedConsumers)
|
||||
{
|
||||
|
||||
@@ -124,7 +124,7 @@ namespace Spring.Messaging.Nms.Support
|
||||
{
|
||||
try
|
||||
{
|
||||
producer.Dispose();
|
||||
producer.Close();
|
||||
}
|
||||
catch (NMSException ex)
|
||||
{
|
||||
|
||||
Reference in New Issue
Block a user