Spring/spring-net
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

misc fixes for broken build

Browse Source
This commit is contained in:
markpollack
2008-07-18 21:42:08 +00:00
parent 92b421f7cb
commit 643578e1e7
4 changed files with 6 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/NmsTransactionManager.cs
View File

@@ -210,10 +210,11 @@ namespace Spring.Messaging.Nms.Connection
LOG.Debug("Committing NMS transaction on Session [" + session + "]");
}
session.Commit();
///https://issues.apache.org/activemq/browse/AMQNET-93
///TODO - need to mirror JMS exception classes in NMS API.
//} catch (TransactionRolledBackException ex)
//{
/** https://issues.apache.org/activemq/browse/AMQNET-93
TODO - need to mirror JMS exception classes in NMS API.
} catch (TransactionRolledBackException ex)
{
*/
}
catch (NMSException ex)

2
src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/SingleConnectionFactory.cs
View File

@@ -267,7 +267,7 @@ namespace Spring.Messaging.Nms.Connection
}
} catch (Exception ex)
{
LOG.Warn("Could not close shared NMS connection.");
LOG.Warn("Could not close shared NMS connection.", ex);
}
}

10
src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/AbstractMessageListenerContainer.cs
View File

@@ -578,16 +578,6 @@ namespace Spring.Messaging.Nms.Listener
#endregion
protected virtual IConnection CreateConnection()
{
return ConnectionFactory.CreateConnection();
}
protected virtual ISession CreateSession(IConnection con)
{
return con.CreateSession(SessionAcknowledgeMode);
}
protected virtual bool IsClientAcknowledge(ISession session)
{
return (session.AcknowledgementMode == AcknowledgementMode.ClientAcknowledge);

2
test/Spring/Spring.Messaging.Nms.Tests/Messaging/Nms/Connections/TestConnection.cs
View File

@@ -8,8 +8,6 @@ namespace Spring.Messaging.Nms.Connection
private int startCount;
private int closeCount;
private int createSessionCount;
private int closeSessionCount;
public int StartCount
{