Dispose SqlCommandBuilder

Particular · Jun 27, 2016 · 8a7b358 · 8a7b358
1 parent ec2ca72
commit 8a7b358
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 9 deletions.
diff --git a/src/NServiceBus.SqlServer/SqlServerMessageSender.cs b/src/NServiceBus.SqlServer/SqlServerMessageSender.cs
@@ -116,12 +116,13 @@ public void Send(TransportMessage message, Address address)
 
         static string SendSqlCommandText(string schemaName, Address address)
         {
-            var sanitizer = new SqlCommandBuilder();
-
-            var quotedSchema = sanitizer.QuoteIdentifier(schemaName);
-            var quotedTable = sanitizer.QuoteIdentifier(TableNameUtils.GetTableName(address));
+            using (var sanitizer = new SqlCommandBuilder())
+            {
+                var quotedSchema = sanitizer.QuoteIdentifier(schemaName);
+                var quotedTable = sanitizer.QuoteIdentifier(TableNameUtils.GetTableName(address));
 
-            return string.Format(SqlSend, quotedSchema, quotedTable);
+                return string.Format(SqlSend, quotedSchema, quotedTable);
+            }
         }
 
         private static void ThrowFailedToSendException(Address address, Exception ex)

diff --git a/src/NServiceBus.SqlServer/SqlServerPollingDequeueStrategy.cs b/src/NServiceBus.SqlServer/SqlServerPollingDequeueStrategy.cs
@@ -63,10 +63,11 @@ public void Init(Address address, TransactionSettings transactionSettings,
                 Timeout = transactionSettings.TransactionTimeout
             };
 
-            var sanitizer = new SqlCommandBuilder();
-
-            quotedSchemaName = sanitizer.QuoteIdentifier(SchemaName);
-            quotedTableName = sanitizer.QuoteIdentifier(TableNameUtils.GetTableName(address));
+            using (var sanitizer = new SqlCommandBuilder())
+            {
+                quotedSchemaName = sanitizer.QuoteIdentifier(SchemaName);
+                quotedTableName = sanitizer.QuoteIdentifier(TableNameUtils.GetTableName(address));
+            }
 
             sql = string.Format(SqlReceive, quotedSchemaName, quotedTableName);