diff --git a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/ConnectionFactoryUtils.cs b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/ConnectionFactoryUtils.cs
index 44f61981..a1b635bb 100644
--- a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/ConnectionFactoryUtils.cs
+++ b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/ConnectionFactoryUtils.cs
@@ -45,7 +45,7 @@ namespace Spring.Messaging.Nms.Connections
///
/// Checks , if available.
/// This is essentially a more sophisticated version of
- ///
+ ///
///
/// The connection to release. (if this is null, the call will be ignored)
/// The ConnectionFactory that the Connection was obtained from. (may be null)
@@ -93,7 +93,7 @@ namespace Spring.Messaging.Nms.Connections
{
return false;
}
- MessageResourceHolder resourceHolder = (MessageResourceHolder) TransactionSynchronizationManager.GetResource(cf);
+ NmsResourceHolder resourceHolder = (NmsResourceHolder) TransactionSynchronizationManager.GetResource(cf);
return (resourceHolder != null && resourceHolder.ContainsSession(session));
}
@@ -140,8 +140,8 @@ namespace Spring.Messaging.Nms.Connections
AssertUtils.ArgumentNotNull(resourceKey, "Resource key must not be null");
AssertUtils.ArgumentNotNull(resourceKey, "ResourceFactory must not be null");
- MessageResourceHolder resourceHolder =
- (MessageResourceHolder)TransactionSynchronizationManager.GetResource(resourceKey);
+ NmsResourceHolder resourceHolder =
+ (NmsResourceHolder)TransactionSynchronizationManager.GetResource(resourceKey);
if (resourceHolder != null)
{
ISession rhSession = resourceFactory.GetSession(resourceHolder);
@@ -162,10 +162,10 @@ namespace Spring.Messaging.Nms.Connections
{
return null;
}
- MessageResourceHolder resourceHolderToUse = resourceHolder;
+ NmsResourceHolder resourceHolderToUse = resourceHolder;
if (resourceHolderToUse == null)
{
- resourceHolderToUse = new MessageResourceHolder();
+ resourceHolderToUse = new NmsResourceHolder();
}
IConnection con = resourceFactory.GetConnection(resourceHolderToUse);
@@ -243,12 +243,12 @@ namespace Spring.Messaging.Nms.Connections
this.synchedLocalTransactionAllowed = synchedLocalTransactionAllowed;
}
- public virtual ISession GetSession(MessageResourceHolder holder)
+ public virtual ISession GetSession(NmsResourceHolder holder)
{
return holder.GetSession(typeof(ISession), existingCon);
}
- public virtual IConnection GetConnection(MessageResourceHolder holder)
+ public virtual IConnection GetConnection(NmsResourceHolder holder)
{
return (existingCon != null ? existingCon : holder.GetConnection());
}
@@ -291,7 +291,7 @@ namespace Spring.Messaging.Nms.Connections
/// an appropriate Session fetched from the holder,
/// or null if none found
///
- ISession GetSession(MessageResourceHolder holder);
+ ISession GetSession(NmsResourceHolder holder);
/// Fetch an appropriate Connection from the given MessageResourceHolder.
/// the MessageResourceHolder
@@ -299,7 +299,7 @@ namespace Spring.Messaging.Nms.Connections
/// an appropriate Connection fetched from the holder,
/// or null if none found
///
- IConnection GetConnection(MessageResourceHolder holder);
+ IConnection GetConnection(NmsResourceHolder holder);
/// Create a new NMS Connection for registration with a MessageResourceHolder.
/// the new NMS Connection
@@ -333,13 +333,13 @@ namespace Spring.Messaging.Nms.Connections
{
private object resourceKey;
- private MessageResourceHolder resourceHolder;
+ private NmsResourceHolder resourceHolder;
private bool transacted;
private bool holderActive = true;
- public MessageResourceSynchronization(object resourceKey, MessageResourceHolder resourceHolder, bool transacted)
+ public MessageResourceSynchronization(object resourceKey, NmsResourceHolder resourceHolder, bool transacted)
{
this.resourceKey = resourceKey;
this.resourceHolder = resourceHolder;
diff --git a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/MessageResourceHolder.cs b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/NmsResourceHolder.cs
similarity index 89%
rename from src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/MessageResourceHolder.cs
rename to src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/NmsResourceHolder.cs
index 2ed240ec..66b1329e 100644
--- a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/MessageResourceHolder.cs
+++ b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/NmsResourceHolder.cs
@@ -37,11 +37,11 @@ namespace Spring.Messaging.Nms.Connections
///
/// Juergen Hoeller
/// Mark Pollack (.NET)
- public class MessageResourceHolder : ResourceHolderSupport
+ public class NmsResourceHolder : ResourceHolderSupport
{
#region Logging
- private static readonly ILog logger = LogManager.GetLogger(typeof(MessageResourceHolder));
+ private static readonly ILog logger = LogManager.GetLogger(typeof(NmsResourceHolder));
#endregion
@@ -63,29 +63,29 @@ namespace Spring.Messaging.Nms.Connections
#region Constructor (s)
/// Create a new MessageResourceHolder that is open for resources to be added.
- public MessageResourceHolder()
+ public NmsResourceHolder()
{
}
///
- /// Initializes a new instance of the class
+ /// Initializes a new instance of the class
/// at is open for resources to be added.
///
/// The connection factory that this
/// resource holder is associated with (may be null)
///
- public MessageResourceHolder(IConnectionFactory connectionFactory)
+ public NmsResourceHolder(IConnectionFactory connectionFactory)
{
this.connectionFactory = connectionFactory;
}
///
- /// Initializes a new instance of the class for the
+ /// Initializes a new instance of the class for the
/// given Session.
///
/// The session.
- public MessageResourceHolder(ISession session)
+ public NmsResourceHolder(ISession session)
{
AddSession(session);
frozen = true;
@@ -96,7 +96,7 @@ namespace Spring.Messaging.Nms.Connections
///
/// the NMS Session
///
- public MessageResourceHolder(IConnection connection, ISession session)
+ public NmsResourceHolder(IConnection connection, ISession session)
{
AddConnection(connection);
AddSession(session, connection);
@@ -104,12 +104,12 @@ namespace Spring.Messaging.Nms.Connections
}
///
- /// Initializes a new instance of the class.
+ /// Initializes a new instance of the class.
///
/// The connection factory.
/// The connection.
/// The session.
- public MessageResourceHolder(IConnectionFactory connectionFactory, IConnection connection, ISession session)
+ public NmsResourceHolder(IConnectionFactory connectionFactory, IConnection connection, ISession session)
{
this.connectionFactory = connectionFactory;
AddConnection(connection);
@@ -121,7 +121,7 @@ namespace Spring.Messaging.Nms.Connections
#region Properties
///
- /// Gets a value indicating whether this is frozen, namely that
+ /// Gets a value indicating whether this is frozen, namely that
/// additional resources can be registered with the holder. If using any of the constructors with
/// a Session, the holder will be set to the frozen state.
///
diff --git a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/MessageTransactionManager.cs b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/NmsTransactionManager.cs
similarity index 92%
rename from src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/MessageTransactionManager.cs
rename to src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/NmsTransactionManager.cs
index 9c7d7423..6a092744 100644
--- a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/MessageTransactionManager.cs
+++ b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/NmsTransactionManager.cs
@@ -40,7 +40,7 @@ namespace Spring.Messaging.Nms.Connections
///
/// Application code is required to retrieve the transactional Session via
/// . Spring's
- /// will autodetect a thread-bound Session and
+ /// will autodetect a thread-bound Session and
/// automatically participate in it.
///
///
@@ -58,20 +58,20 @@ namespace Spring.Messaging.Nms.Connections
///
/// Juergen Hoeller
/// Mark Pollack (.NET)
- public class MessageTransactionManager : AbstractPlatformTransactionManager,
+ public class NmsTransactionManager : AbstractPlatformTransactionManager,
IResourceTransactionManager, IInitializingObject
{
#region Logging Definition
- private static readonly ILog LOG = LogManager.GetLogger(typeof(MessageTransactionManager));
+ private static readonly ILog LOG = LogManager.GetLogger(typeof(NmsTransactionManager));
#endregion
private IConnectionFactory connectionFactory;
///
- /// Initializes a new instance of the class.
+ /// Initializes a new instance of the class.
///
///
/// The ConnectionFactory has to be set before using the instance.
@@ -84,17 +84,17 @@ namespace Spring.Messaging.Nms.Connections
/// Only one manager is allowed to drive synchronization at any point of time.
///
///
- public MessageTransactionManager()
+ public NmsTransactionManager()
{
TransactionSynchronization = TransactionSynchronizationState.Never;
}
///
- /// Initializes a new instance of the class
+ /// Initializes a new instance of the class
/// given a ConnectionFactory.
///
/// The connection factory to obtain connections from.
- public MessageTransactionManager(IConnectionFactory connectionFactory) : this()
+ public NmsTransactionManager(IConnectionFactory connectionFactory) : this()
{
ConnectionFactory = connectionFactory;
AfterPropertiesSet();
@@ -154,7 +154,7 @@ namespace Spring.Messaging.Nms.Connections
MessageTransactionObject txObject = new MessageTransactionObject();
txObject.ResourceHolder =
- (MessageResourceHolder) TransactionSynchronizationManager.GetResource(ConnectionFactory);
+ (NmsResourceHolder) TransactionSynchronizationManager.GetResource(ConnectionFactory);
return txObject;
}
@@ -191,7 +191,7 @@ namespace Spring.Messaging.Nms.Connections
{
log.Debug("Created NMS transaction on Session [" + session + "] from Connection [" + con + "]");
}
- txObject.ResourceHolder = new MessageResourceHolder(ConnectionFactory, con, session);
+ txObject.ResourceHolder = new NmsResourceHolder(ConnectionFactory, con, session);
txObject.ResourceHolder.SynchronizedWithTransaction = true;
int timeout = DetermineTimeout(definition);
if (timeout != DefaultTransactionDefinition.TIMEOUT_DEFAULT)
@@ -260,7 +260,7 @@ namespace Spring.Messaging.Nms.Connections
///
protected override void DoResume(object transaction, object suspendedResources)
{
- MessageResourceHolder conHolder = (MessageResourceHolder) suspendedResources;
+ NmsResourceHolder conHolder = (NmsResourceHolder) suspendedResources;
TransactionSynchronizationManager.BindResource(ConnectionFactory, conHolder);
}
@@ -402,10 +402,10 @@ namespace Spring.Messaging.Nms.Connections
///
internal class MessageTransactionObject : ISmartTransactionObject
{
- private MessageResourceHolder resourceHolder;
+ private NmsResourceHolder resourceHolder;
- public MessageResourceHolder ResourceHolder
+ public NmsResourceHolder ResourceHolder
{
get { return resourceHolder; }
set { resourceHolder = value; }
diff --git a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/SingleConnectionFactory.cs b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/SingleConnectionFactory.cs
index 4aa83045..52aefe30 100644
--- a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/SingleConnectionFactory.cs
+++ b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Connections/SingleConnectionFactory.cs
@@ -38,7 +38,7 @@ namespace Spring.Messaging.Nms.Connections
/// You can either pass in a specific Connection directly or let this
/// factory lazily create a Connection via a given target ConnectionFactory.
/// Useful in order to keep using the same Connection for multiple
- /// calls, without having a pooling ConnectionFactory
+ /// calls, without having a pooling ConnectionFactory
/// underneath. This may span any number of transactions, even concurrently executing transactions.
///
///
diff --git a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/IMessageOperations.cs b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/INmsOperations.cs
similarity index 97%
rename from src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/IMessageOperations.cs
rename to src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/INmsOperations.cs
index 06412a33..228bb586 100644
--- a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/IMessageOperations.cs
+++ b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/INmsOperations.cs
@@ -36,7 +36,7 @@ namespace Spring.Messaging.Nms.Core
/// Mark Pollack
/// Juergen Hoeller
/// Mark Pollack (.NET)
- public interface IMessageOperations
+ public interface INmsOperations
{
/// Execute the action specified by the given action object within
/// a NMS Session.
diff --git a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/ISessionCallback.cs b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/ISessionCallback.cs
index 26e29bad..daa7914c 100644
--- a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/ISessionCallback.cs
+++ b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/ISessionCallback.cs
@@ -31,7 +31,7 @@ namespace Spring.Messaging.Nms.Core
/// that can be used as a (anonymous) delegate.
///
/// Mark Pollack
- ///
+ ///
///
public interface ISessionCallback
{
diff --git a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/MessagingGatewaySupport.cs b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/NmsGatewaySupport.cs
similarity index 88%
rename from src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/MessagingGatewaySupport.cs
rename to src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/NmsGatewaySupport.cs
index bdd3f2c6..858481f7 100644
--- a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/MessagingGatewaySupport.cs
+++ b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/NmsGatewaySupport.cs
@@ -35,23 +35,23 @@ namespace Spring.Messaging.Nms.Core
/// through overriding the createNmsTemplate method.
///
///
- public class MessageGatewaySupport : IInitializingObject
+ public class NmsGatewaySupport : IInitializingObject
{
#region Logging
- private readonly ILog logger = LogManager.GetLogger(typeof(MessageGatewaySupport));
+ private readonly ILog logger = LogManager.GetLogger(typeof(NmsGatewaySupport));
#endregion
- private MessageTemplate jmsTemplate;
+ private NmsTemplate jmsTemplate;
///
/// Gets or sets the NMS template for the gateway.
///
/// The NMS template.
- public MessageTemplate MessageTemplate
+ public NmsTemplate NmsTemplate
{
get { return jmsTemplate; }
set { jmsTemplate = value; }
@@ -83,9 +83,9 @@ namespace Spring.Messaging.Nms.Core
///
/// The connection factory.
///
- protected virtual MessageTemplate CreateNmsTemplate(IConnectionFactory connectionFactory)
+ protected virtual NmsTemplate CreateNmsTemplate(IConnectionFactory connectionFactory)
{
- return new MessageTemplate(connectionFactory);
+ return new NmsTemplate(connectionFactory);
}
///
diff --git a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/MessageTemplate.cs b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/NmsTemplate.cs
similarity index 92%
rename from src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/MessageTemplate.cs
rename to src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/NmsTemplate.cs
index 8dd48759..38a18ae1 100644
--- a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/MessageTemplate.cs
+++ b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Core/NmsTemplate.cs
@@ -47,11 +47,11 @@ namespace Spring.Messaging.Nms.Core
/// Mark Pollack
/// Juergen Hoeller
/// Mark Pollack (.NET)
- public class MessageTemplate : MessageDestinationAccessor, IMessageOperations
+ public class NmsTemplate : NmsDestinationAccessor, INmsOperations
{
#region Logging
- private readonly ILog logger = LogManager.GetLogger(typeof(MessageTemplate));
+ private readonly ILog logger = LogManager.GetLogger(typeof(NmsTemplate));
#endregion
@@ -96,7 +96,7 @@ namespace Spring.Messaging.Nms.Core
/// This constructor can be used to prepare a MessageTemplate via an ObjectFactory,
/// typically setting the ConnectionFactory.
///
- public MessageTemplate()
+ public NmsTemplate()
{
transactionalResourceFactory = new MessageTemplateResourceFactory(this);
InitDefaultStrategies();
@@ -106,7 +106,7 @@ namespace Spring.Messaging.Nms.Core
/// Create a new MessageTemplate, given a ConnectionFactory.
/// the ConnectionFactory to obtain IConnections from
///
- public MessageTemplate(IConnectionFactory connectionFactory)
+ public NmsTemplate(IConnectionFactory connectionFactory)
: this()
{
ConnectionFactory = connectionFactory;
@@ -188,7 +188,7 @@ namespace Spring.Messaging.Nms.Core
}
finally
{
- MessagingUtils.CloseSession(sessionToClose);
+ NmsUtils.CloseSession(sessionToClose);
ConnectionFactoryUtils.ReleaseConnection(conToClose, ConnectionFactory, startConnection);
}
}
@@ -376,7 +376,7 @@ namespace Spring.Messaging.Nms.Core
/// an appropriate IConnection fetched from the holder,
/// or null if none found
///
- protected virtual IConnection GetConnection(MessageResourceHolder holder)
+ protected virtual IConnection GetConnection(NmsResourceHolder holder)
{
return holder.GetConnection();
}
@@ -388,7 +388,7 @@ namespace Spring.Messaging.Nms.Core
/// an appropriate ISession fetched from the holder,
/// or null if none found
///
- protected virtual ISession GetSession(MessageResourceHolder holder)
+ protected virtual ISession GetSession(NmsResourceHolder holder)
{
return holder.GetSession();
}
@@ -548,12 +548,12 @@ namespace Spring.Messaging.Nms.Core
if (session.Transacted && IsSessionLocallyTransacted(session))
{
// Transacted session created by this template -> commit.
- MessagingUtils.CommitIfNecessary(session);
+ NmsUtils.CommitIfNecessary(session);
}
}
finally
{
- MessagingUtils.CloseMessageProducer(producer);
+ NmsUtils.CloseMessageProducer(producer);
}
}
@@ -969,8 +969,8 @@ namespace Spring.Messaging.Nms.Core
try
{
long timeout = ReceiveTimeout;
- MessageResourceHolder resourceHolder =
- (MessageResourceHolder)TransactionSynchronizationManager.GetResource(ConnectionFactory);
+ NmsResourceHolder resourceHolder =
+ (NmsResourceHolder)TransactionSynchronizationManager.GetResource(ConnectionFactory);
if (resourceHolder != null && resourceHolder.HasTimeout)
{
timeout = Convert.ToInt64(resourceHolder.TimeToLiveInMilliseconds);
@@ -984,7 +984,7 @@ namespace Spring.Messaging.Nms.Core
if (IsSessionLocallyTransacted(session))
{
// Transacted session created by this template -> commit.
- MessagingUtils.CommitIfNecessary(session);
+ NmsUtils.CommitIfNecessary(session);
}
}
else if (IsClientAcknowledge(session))
@@ -999,7 +999,7 @@ namespace Spring.Messaging.Nms.Core
}
finally
{
- MessagingUtils.CloseMessageConsumer(consumer);
+ NmsUtils.CloseMessageConsumer(consumer);
}
}
@@ -1125,29 +1125,29 @@ namespace Spring.Messaging.Nms.Core
///
private class MessageTemplateResourceFactory : ConnectionFactoryUtils.ResourceFactory
{
- private MessageTemplate enclosingTemplateInstance;
+ private NmsTemplate enclosingTemplateInstance;
- public MessageTemplateResourceFactory(MessageTemplate enclosingInstance)
+ public MessageTemplateResourceFactory(NmsTemplate enclosingInstance)
{
InitBlock(enclosingInstance);
}
- private void InitBlock(MessageTemplate enclosingInstance)
+ private void InitBlock(NmsTemplate enclosingInstance)
{
enclosingTemplateInstance = enclosingInstance;
}
- public MessageTemplate EnclosingInstance
+ public NmsTemplate EnclosingInstance
{
get { return enclosingTemplateInstance; }
}
- public virtual IConnection GetConnection(MessageResourceHolder holder)
+ public virtual IConnection GetConnection(NmsResourceHolder holder)
{
return EnclosingInstance.GetConnection(holder);
}
- public virtual ISession GetSession(MessageResourceHolder holder)
+ public virtual ISession GetSession(NmsResourceHolder holder)
{
return EnclosingInstance.GetSession(holder);
}
@@ -1170,10 +1170,10 @@ namespace Spring.Messaging.Nms.Core
private class ProducerCreatorCallback : ISessionCallback
{
- private MessageTemplate jmsTemplate;
+ private NmsTemplate jmsTemplate;
private IProducerCallback producerCallback;
- public ProducerCreatorCallback(MessageTemplate jmsTemplate, IProducerCallback producerCallback)
+ public ProducerCreatorCallback(NmsTemplate jmsTemplate, IProducerCallback producerCallback)
{
this.jmsTemplate = jmsTemplate;
this.producerCallback = producerCallback;
@@ -1188,7 +1188,7 @@ namespace Spring.Messaging.Nms.Core
}
finally
{
- MessagingUtils.CloseMessageProducer(producer);
+ NmsUtils.CloseMessageProducer(producer);
}
}
@@ -1196,18 +1196,18 @@ namespace Spring.Messaging.Nms.Core
private class ReceiveCallback : ISessionCallback
{
- private MessageTemplate jmsTemplate;
+ private NmsTemplate jmsTemplate;
private IDestination destination;
private string destinationName;
- public ReceiveCallback(MessageTemplate jmsTemplate, string destinationName)
+ public ReceiveCallback(NmsTemplate jmsTemplate, string destinationName)
{
this.jmsTemplate = jmsTemplate;
this.destinationName = destinationName;
}
- public ReceiveCallback(MessageTemplate jmsTemplate, IDestination destination)
+ public ReceiveCallback(NmsTemplate jmsTemplate, IDestination destination)
{
this.jmsTemplate = jmsTemplate;
this.destination = destination;
@@ -1231,11 +1231,11 @@ namespace Spring.Messaging.Nms.Core
private class ConvertAndSendMessageCreator : IMessageCreator
{
- private MessageTemplate jmsTemplate;
+ private NmsTemplate jmsTemplate;
private object objectToConvert;
private IMessagePostProcessor messagePostProcessor;
- public ConvertAndSendMessageCreator(MessageTemplate jmsTemplate, object message, IMessagePostProcessor messagePostProcessor)
+ public ConvertAndSendMessageCreator(NmsTemplate jmsTemplate, object message, IMessagePostProcessor messagePostProcessor)
{
this.jmsTemplate = jmsTemplate;
objectToConvert = message;
@@ -1251,12 +1251,12 @@ namespace Spring.Messaging.Nms.Core
private class ReceiveSelectedCallback : ISessionCallback
{
- private MessageTemplate jmsTemplate;
+ private NmsTemplate jmsTemplate;
private string messageSelector;
private string destinationName;
private IDestination destination;
- public ReceiveSelectedCallback(MessageTemplate jmsTemplate,
+ public ReceiveSelectedCallback(NmsTemplate jmsTemplate,
IDestination destination,
string messageSelector)
{
@@ -1264,7 +1264,7 @@ namespace Spring.Messaging.Nms.Core
this.destination = destination;
this.messageSelector = messageSelector;
}
- public ReceiveSelectedCallback(MessageTemplate jmsTemplate,
+ public ReceiveSelectedCallback(NmsTemplate jmsTemplate,
string destinationName,
string messageSelector)
{
@@ -1311,10 +1311,10 @@ namespace Spring.Messaging.Nms.Core
internal class SimpleMessageCreator : IMessageCreator
{
- private MessageTemplate jmsTemplate;
+ private NmsTemplate jmsTemplate;
private object objectToConvert;
- public SimpleMessageCreator(MessageTemplate jmsTemplate, object objectToConvert)
+ public SimpleMessageCreator(NmsTemplate jmsTemplate, object objectToConvert)
{
this.jmsTemplate = jmsTemplate;
this.objectToConvert = objectToConvert;
@@ -1334,32 +1334,32 @@ namespace Spring.Messaging.Nms.Core
{
private string destinationName;
private IDestination destination;
- private MessageTemplate jmsTemplate;
+ private NmsTemplate jmsTemplate;
private IMessageCreator messageCreator;
private IMessageCreatorDelegate messageCreatorDelegate;
- public SendDestinationCallback(MessageTemplate jmsTemplate, string destinationName, IMessageCreator messageCreator)
+ public SendDestinationCallback(NmsTemplate jmsTemplate, string destinationName, IMessageCreator messageCreator)
{
this.jmsTemplate = jmsTemplate;
this.destinationName = destinationName;
this.messageCreator = messageCreator;
}
- public SendDestinationCallback(MessageTemplate jmsTemplate, IDestination destination, IMessageCreator messageCreator)
+ public SendDestinationCallback(NmsTemplate jmsTemplate, IDestination destination, IMessageCreator messageCreator)
{
this.jmsTemplate = jmsTemplate;
this.destination = destination;
this.messageCreator = messageCreator;
}
- public SendDestinationCallback(MessageTemplate jmsTemplate, string destinationName, IMessageCreatorDelegate messageCreatorDelegate)
+ public SendDestinationCallback(NmsTemplate jmsTemplate, string destinationName, IMessageCreatorDelegate messageCreatorDelegate)
{
this.jmsTemplate = jmsTemplate;
this.destinationName = destinationName;
this.messageCreatorDelegate = messageCreatorDelegate;
}
- public SendDestinationCallback(MessageTemplate jmsTemplate, IDestination destination, IMessageCreatorDelegate messageCreatorDelegate)
+ public SendDestinationCallback(NmsTemplate jmsTemplate, IDestination destination, IMessageCreatorDelegate messageCreatorDelegate)
{
this.jmsTemplate = jmsTemplate;
this.destination = destination;
diff --git a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/AbstractListenerContainer.cs b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/AbstractListenerContainer.cs
index ec093e5a..fef4e4f2 100644
--- a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/AbstractListenerContainer.cs
+++ b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/AbstractListenerContainer.cs
@@ -33,7 +33,7 @@ namespace Spring.Messaging.Nms.Listener
/// Common base class for all containers which need to implement listening
/// based on a Connection (either shared or freshly obtained for each attempt).
/// Inherits basic Connection and Session configuration handling from the
- /// base class.
+ /// base class.
///
///
/// This class provides basic lifecycle management, in particular management
@@ -45,7 +45,7 @@ namespace Spring.Messaging.Nms.Listener
///
///
/// Mark Pollack
- public abstract class AbstractListenerContainer : MessageDestinationAccessor, ILifecycle, IObjectNameAware, IDisposable
+ public abstract class AbstractListenerContainer : NmsDestinationAccessor, ILifecycle, IObjectNameAware, IDisposable
{
#region Logging
@@ -473,7 +473,7 @@ namespace Spring.Messaging.Nms.Listener
return con;
} catch (NMSException)
{
- MessagingUtils.CloseConnection(con);
+ NmsUtils.CloseConnection(con);
throw;
}
}
diff --git a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/AbstractMessageListenerContainer.cs b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/AbstractMessageListenerContainer.cs
index 9c18fa96..2233deab 100644
--- a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/AbstractMessageListenerContainer.cs
+++ b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/AbstractMessageListenerContainer.cs
@@ -209,7 +209,7 @@ namespace Spring.Messaging.Nms.Listener
///
/// Gets or sets a value indicating whether to expose listener session to a registered
- /// as well as to calls.
+ /// as well as to calls.
///
///
/// Default is "true", reusing the listener's Session.
@@ -217,7 +217,7 @@ namespace Spring.Messaging.Nms.Listener
/// underlying Connection instead, which might be necessary
/// on some messaging providers.
/// Note that Sessions managed by an external transaction manager will
- /// always get exposed to
+ /// always get exposed to
/// calls. So in terms of MessageTemplate exposure, this setting only affects
/// locally transacted Sessions.
///
@@ -412,13 +412,13 @@ namespace Spring.Messaging.Nms.Listener
if (sessionToUse.Transacted && SessionTransacted)
{
// Transacted session created by this container -> commit.
- MessagingUtils.CommitIfNecessary(sessionToUse);
+ NmsUtils.CommitIfNecessary(sessionToUse);
}
}
} finally
{
- MessagingUtils.CloseSession(sessionToClose);
- MessagingUtils.CloseConnection(conToClose);
+ NmsUtils.CloseSession(sessionToClose);
+ NmsUtils.CloseConnection(conToClose);
}
}
@@ -449,7 +449,7 @@ namespace Spring.Messaging.Nms.Listener
// Commit necessary - but avoid commit call is Session transaction is externally coordinated.
if (IsSessionLocallyTransacted(session))
{
- MessagingUtils.CommitIfNecessary(session);
+ NmsUtils.CommitIfNecessary(session);
}
}
else if (IsClientAcknowledge(session))
@@ -472,7 +472,7 @@ namespace Spring.Messaging.Nms.Listener
///
/// true if the is session locally transacted; otherwise, false.
///
- ///
+ ///
protected virtual bool IsSessionLocallyTransacted(ISession session)
{
return SessionTransacted;
@@ -489,7 +489,7 @@ namespace Spring.Messaging.Nms.Listener
if (session.Transacted && IsSessionLocallyTransacted(session))
{
// Transacted session created by this container -> rollback
- MessagingUtils.RollbackIfNecessary(session);
+ NmsUtils.RollbackIfNecessary(session);
}
}
///
@@ -509,7 +509,7 @@ namespace Spring.Messaging.Nms.Listener
{
logger.Debug("Initiating transaction rollback on application exception");
}
- MessagingUtils.RollbackIfNecessary(session);
+ NmsUtils.RollbackIfNecessary(session);
}
} catch (NMSException)
{
diff --git a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/Adapter/MessageListenerAdapter.cs b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/Adapter/MessageListenerAdapter.cs
index c3480c3c..95675705 100644
--- a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/Adapter/MessageListenerAdapter.cs
+++ b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/Adapter/MessageListenerAdapter.cs
@@ -530,7 +530,7 @@ namespace Spring.Messaging.Nms.Listener.Adapter
}
finally
{
- MessagingUtils.CloseMessageProducer(producer);
+ NmsUtils.CloseMessageProducer(producer);
}
}
diff --git a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/LocallyExposedMessageResourceHolder.cs b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/LocallyExposedNmsResourceHolder.cs
similarity index 83%
rename from src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/LocallyExposedMessageResourceHolder.cs
rename to src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/LocallyExposedNmsResourceHolder.cs
index c17b4da2..bf64d759 100644
--- a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/LocallyExposedMessageResourceHolder.cs
+++ b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/LocallyExposedNmsResourceHolder.cs
@@ -29,13 +29,13 @@ namespace Spring.Messaging.Nms.Listener
///
/// Juergen Hoeller
/// Mark Pollack (.NET)
- public class LocallyExposedMessageResourceHolder : MessageResourceHolder
+ public class LocallyExposedNmsResourceHolder : NmsResourceHolder
{
///
- /// Initializes a new instance of the class.
+ /// Initializes a new instance of the class.
///
/// The session.
- public LocallyExposedMessageResourceHolder(ISession session) : base(session)
+ public LocallyExposedNmsResourceHolder(ISession session) : base(session)
{
}
diff --git a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/SimpleMessageListenerContainer.cs b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/SimpleMessageListenerContainer.cs
index f71dd049..890297d8 100644
--- a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/SimpleMessageListenerContainer.cs
+++ b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Listener/SimpleMessageListenerContainer.cs
@@ -237,12 +237,12 @@ namespace Spring.Messaging.Nms.Listener
logger.Debug("Closing NMS MessageConsumers");
foreach (IMessageConsumer messageConsumer in consumers)
{
- MessagingUtils.CloseMessageConsumer(messageConsumer);
+ NmsUtils.CloseMessageConsumer(messageConsumer);
}
logger.Debug("Closing NMS Sessions");
foreach (ISession session in sessions)
{
- MessagingUtils.CloseSession(session);
+ NmsUtils.CloseSession(session);
}
consumers = null;
sessions = null;
@@ -296,7 +296,7 @@ namespace Spring.Messaging.Nms.Listener
if (exposeResource)
{
TransactionSynchronizationManager.BindResource(
- container.ConnectionFactory, new LocallyExposedMessageResourceHolder(session));
+ container.ConnectionFactory, new LocallyExposedNmsResourceHolder(session));
}
try
{
diff --git a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Support/Destinations/MessageDestinationAccessor.cs b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Support/Destinations/NmsDestinationAccessor.cs
similarity index 94%
rename from src/Spring/Spring.Messaging.Nms/Messaging/Nms/Support/Destinations/MessageDestinationAccessor.cs
rename to src/Spring/Spring.Messaging.Nms/Messaging/Nms/Support/Destinations/NmsDestinationAccessor.cs
index 81ccb6c2..ff627255 100644
--- a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Support/Destinations/MessageDestinationAccessor.cs
+++ b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Support/Destinations/NmsDestinationAccessor.cs
@@ -18,8 +18,6 @@
#endregion
-using System;
-using Spring.Objects.Factory;
using Spring.Util;
using Apache.NMS;
@@ -35,7 +33,7 @@ namespace Spring.Messaging.Nms.Support.Destinations
///
/// Juergen Hoeller
/// Mark Pollack (.NET)
- public class MessageDestinationAccessor : MessagingAccessor
+ public class NmsDestinationAccessor : NmsAccessor
{
#region Fields
diff --git a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Support/MessageUtils.cs b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Support/MessageUtils.cs
index 8903083f..47f3134b 100644
--- a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Support/MessageUtils.cs
+++ b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Support/MessageUtils.cs
@@ -29,11 +29,11 @@ namespace Spring.Messaging.Nms.Support
/// Generic utility methods for working with NMS. Mainly for internal use
/// within the framework, but also useful for custom NMS access code.
///
- public abstract class MessagingUtils
+ public abstract class NmsUtils
{
#region Logging
- private static readonly ILog logger = LogManager.GetLogger(typeof(MessagingUtils));
+ private static readonly ILog logger = LogManager.GetLogger(typeof(NmsUtils));
#endregion
diff --git a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Support/MessageAccessor.cs b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Support/NmsAccessor.cs
similarity index 95%
rename from src/Spring/Spring.Messaging.Nms/Messaging/Nms/Support/MessageAccessor.cs
rename to src/Spring/Spring.Messaging.Nms/Messaging/Nms/Support/NmsAccessor.cs
index 24704c98..7e5c4b4e 100644
--- a/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Support/MessageAccessor.cs
+++ b/src/Spring/Spring.Messaging.Nms/Messaging/Nms/Support/NmsAccessor.cs
@@ -34,11 +34,11 @@ namespace Spring.Messaging.Nms.Support
///
/// Juergen Hoeller
/// Mark Pollack (.NET)
- public class MessagingAccessor : IInitializingObject
+ public class NmsAccessor : IInitializingObject
{
#region Logging
- private readonly ILog logger = LogManager.GetLogger(typeof(MessagingAccessor));
+ private readonly ILog logger = LogManager.GetLogger(typeof(NmsAccessor));
#endregion
diff --git a/src/Spring/Spring.Messaging.Nms/Spring.Messaging.Nms.2005.csproj b/src/Spring/Spring.Messaging.Nms/Spring.Messaging.Nms.2005.csproj
index c3b40f47..20e4ae35 100644
--- a/src/Spring/Spring.Messaging.Nms/Spring.Messaging.Nms.2005.csproj
+++ b/src/Spring/Spring.Messaging.Nms/Spring.Messaging.Nms.2005.csproj
@@ -50,13 +50,13 @@
-
+
-
-
+
+
@@ -67,8 +67,8 @@
-
-
+
+
@@ -76,15 +76,15 @@
-
+
-
-
+
+
diff --git a/test/Spring/Spring.Messaging.Nms.Tests/Messaging/Nms/Connections/MessageTransactionManagerTests.cs b/test/Spring/Spring.Messaging.Nms.Tests/Messaging/Nms/Connections/MessageTransactionManagerTests.cs
index f44574c7..5dd745db 100644
--- a/test/Spring/Spring.Messaging.Nms.Tests/Messaging/Nms/Connections/MessageTransactionManagerTests.cs
+++ b/test/Spring/Spring.Messaging.Nms.Tests/Messaging/Nms/Connections/MessageTransactionManagerTests.cs
@@ -63,9 +63,9 @@ namespace Spring.Messaging.Nms.Connections
mocks.ReplayAll();
- MessageTransactionManager tm = new MessageTransactionManager(connectionFactory);
+ NmsTransactionManager tm = new NmsTransactionManager(connectionFactory);
ITransactionStatus ts = tm.GetTransaction(new DefaultTransactionDefinition());
- MessageTemplate nt = new MessageTemplate(connectionFactory);
+ NmsTemplate nt = new NmsTemplate(connectionFactory);
nt.Execute(new AssertSessionCallback(session));
tm.Commit(ts);
@@ -84,9 +84,9 @@ namespace Spring.Messaging.Nms.Connections
mocks.ReplayAll();
- MessageTransactionManager tm = new MessageTransactionManager(connectionFactory);
+ NmsTransactionManager tm = new NmsTransactionManager(connectionFactory);
ITransactionStatus ts = tm.GetTransaction(new DefaultTransactionDefinition());
- MessageTemplate nt = new MessageTemplate(connectionFactory);
+ NmsTemplate nt = new NmsTemplate(connectionFactory);
nt.Execute(new AssertSessionCallback(session));
tm.Rollback(ts);
@@ -112,9 +112,9 @@ namespace Spring.Messaging.Nms.Connections
mocks.ReplayAll();
- MessageTransactionManager tm = new MessageTransactionManager(connectionFactory);
+ NmsTransactionManager tm = new NmsTransactionManager(connectionFactory);
ITransactionStatus ts = tm.GetTransaction(new DefaultTransactionDefinition());
- MessageTemplate nt = new MessageTemplate(connectionFactory);
+ NmsTemplate nt = new NmsTemplate(connectionFactory);
nt.Execute(new AssertSessionCallback(session));
TransactionTemplate tt = new TransactionTemplate(tm);
@@ -144,9 +144,9 @@ namespace Spring.Messaging.Nms.Connections
mocks.ReplayAll();
- MessageTransactionManager tm = new MessageTransactionManager(connectionFactory);
+ NmsTransactionManager tm = new NmsTransactionManager(connectionFactory);
ITransactionStatus ts = tm.GetTransaction(new DefaultTransactionDefinition());
- MessageTemplate nt = new MessageTemplate(connectionFactory);
+ NmsTemplate nt = new NmsTemplate(connectionFactory);
nt.Execute(new AssertSessionCallback(session));
TransactionTemplate tt = new TransactionTemplate(tm);
@@ -193,9 +193,9 @@ namespace Spring.Messaging.Nms.Connections
mocks.ReplayAll();
- MessageTransactionManager tm = new MessageTransactionManager(connectionFactory);
+ NmsTransactionManager tm = new NmsTransactionManager(connectionFactory);
ITransactionStatus ts = tm.GetTransaction(new DefaultTransactionDefinition());
- MessageTemplate nt = new MessageTemplate(connectionFactory);
+ NmsTemplate nt = new NmsTemplate(connectionFactory);
nt.Execute(new AssertSessionCallback(session));
TransactionTemplate tt = new TransactionTemplate(tm);
@@ -242,9 +242,9 @@ namespace Spring.Messaging.Nms.Connections
mocks.ReplayAll();
- MessageTransactionManager tm = new MessageTransactionManager(connectionFactory);
+ NmsTransactionManager tm = new NmsTransactionManager(connectionFactory);
ITransactionStatus ts = tm.GetTransaction(new DefaultTransactionDefinition());
- MessageTemplate nt = new MessageTemplate(connectionFactory);
+ NmsTemplate nt = new NmsTemplate(connectionFactory);
TransactionTemplate tt = new TransactionTemplate(tm);
diff --git a/test/Spring/Spring.Messaging.Nms.Tests/Messaging/Nms/Core/MessageTemplateTests.cs b/test/Spring/Spring.Messaging.Nms.Tests/Messaging/Nms/Core/MessageTemplateTests.cs
index 00dc0496..cffd2a90 100644
--- a/test/Spring/Spring.Messaging.Nms.Tests/Messaging/Nms/Core/MessageTemplateTests.cs
+++ b/test/Spring/Spring.Messaging.Nms.Tests/Messaging/Nms/Core/MessageTemplateTests.cs
@@ -54,9 +54,9 @@ namespace Spring.Messaging.Nms.Core
CreateMocks();
}
- private MessageTemplate CreateTemplate()
+ private NmsTemplate CreateTemplate()
{
- MessageTemplate template = new MessageTemplate();
+ NmsTemplate template = new NmsTemplate();
template.DestinationResolver = mockDestinationResolver;
template.SessionTransacted = UseTransactedTemplate;
return template;
@@ -103,7 +103,7 @@ namespace Spring.Messaging.Nms.Core
[Test]
public void SessionCallback()
{
- MessageTemplate template = CreateTemplate();
+ NmsTemplate template = CreateTemplate();
template.ConnectionFactory = mockConnectionFactory;
mockSession.Close();
LastCall.On(mockSession).Repeat.Once();
@@ -124,7 +124,7 @@ namespace Spring.Messaging.Nms.Core
public void SessionCallbackWithinSynchronizedTransaction()
{
SingleConnectionFactory scf = new SingleConnectionFactory(mockConnectionFactory);
- MessageTemplate template = CreateTemplate();
+ NmsTemplate template = CreateTemplate();
template.ConnectionFactory = scf;
mockConnection.Start();
diff --git a/test/Spring/Spring.Messaging.Nms.Tests/Messaging/Nms/Integration/SimpleMessageListenerContainerTests.cs b/test/Spring/Spring.Messaging.Nms.Tests/Messaging/Nms/Integration/SimpleMessageListenerContainerTests.cs
index 4b92842a..935af7e1 100644
--- a/test/Spring/Spring.Messaging.Nms.Tests/Messaging/Nms/Integration/SimpleMessageListenerContainerTests.cs
+++ b/test/Spring/Spring.Messaging.Nms.Tests/Messaging/Nms/Integration/SimpleMessageListenerContainerTests.cs
@@ -51,11 +51,11 @@ namespace Spring.Messaging.Nms.Integration
Assert.IsNotNull(listener);
- MessageTemplate messageTemplate = (MessageTemplate) applicationContext["MessageTemplate"] as MessageTemplate;
- Assert.IsNotNull(messageTemplate);
+ NmsTemplate nmsTemplate = (NmsTemplate) applicationContext["MessageTemplate"] as NmsTemplate;
+ Assert.IsNotNull(nmsTemplate);
Assert.AreEqual(0, listener.MessageCount);
- messageTemplate.ConvertAndSend("Hello World 1");
+ nmsTemplate.ConvertAndSend("Hello World 1");
int waitInMillis = 2000;
Thread.Sleep(waitInMillis);
@@ -63,7 +63,7 @@ namespace Spring.Messaging.Nms.Integration
container.Stop();
Console.WriteLine("container stopped.");
- messageTemplate.ConvertAndSend("Hello World 2");
+ nmsTemplate.ConvertAndSend("Hello World 2");
Thread.Sleep(waitInMillis);
Assert.AreEqual(1, listener.MessageCount);