--- dao/DaoMqPump2/DaoMqPump2/Transport.cs	2013/07/09 19:37:14	2009
+++ dao/DaoMqPump2/DaoMqPump2/Transport.cs	2013/07/10 18:28:31	2010
@@ -153,13 +153,16 @@
 
                 //stage 2 connect to mysql
                 string mysqlString = buildMysqlConnString();
-                MySqlConnection sqlConnection = new MySqlConnection(mysqlString);
-                sqlConnection.Open();
+                MySqlConnection sqlReadConnection = new MySqlConnection(mysqlString);
+                sqlReadConnection.Open();
+
+                MySqlConnection sqlWriteConnection = new MySqlConnection(mysqlString);
+                sqlWriteConnection.Open();
 
 
                 //stage 3 move messages
                 string readSql = "CALL " + sql2mqReadQuery + "()";
-                MySqlCommand readCmd = new MySqlCommand(readSql, sqlConnection);
+                MySqlCommand readCmd = new MySqlCommand(readSql, sqlReadConnection);
                 MySqlDataReader dataReader = readCmd.ExecuteReader();
                 while (dataReader.Read())
                 {
@@ -179,7 +182,7 @@
                     //now that the message has been put on queue mark it as such
 
                     string updateSql = "CALL " + sql2mqUpdateQuery + "(" + id + ")";
-                    MySqlCommand updateCmd = new MySqlCommand(updateSql, sqlConnection);
+                    MySqlCommand updateCmd = new MySqlCommand(updateSql, sqlWriteConnection);
                     int numrows = updateCmd.ExecuteNonQuery();
 
                     translog.WriteLine(getNowString() + " " + msgString + "\n");
@@ -196,7 +199,8 @@
                 dataReader.Close();
                 out_queue.Close();
                 mqMgr.Close();
-                sqlConnection.Close();
+                sqlReadConnection.Close();
+                sqlWriteConnection.Close();
             }
             catch (Exception e)
             {