C#

// Send Message
private void btnSendMessage_Click(object sender, System.EventArgs e)
{

       // Open queue
       System.Messaging.MessageQueue queue = 
                    new System.Messaging.MessageQueue(".\\Private$\\MSMQDemo");

       // Create message
       System.Messaging.Message message = new System.Messaging.Message();

       message.Body = txtMessage.Text.Trim();

       message.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] {typeof(string)});

       // Put message into queue
       queue.Send(message);

}

 

// Receive Message
private void btnReceiveMessage_Click(object sender, System.EventArgs e)
{

       // Open queue
       System.Messaging.MessageQueue queue = 
                   new System.Messaging.MessageQueue(".\\Private$\\MSMQDemo");

 
      // Receive message
        System.Messaging.Message message = queue.Receive(); 

       message.Formatter = new System.Messaging.XmlMessageFormatter(new Type[] {typeof(string)});

       txtReceiveMessage.Text = message.Body.ToString();
}

private void SelectAll_Click(object sender, EventArgs e)
       {
           if (SelectAll.Checked)
           {
               cb.Select();
               cb1.Select();
           }
       }

using (SqlConnection con = new SqlConnection("data source=.;initial catalog=test;Trusted_Connection=Yes"))
            {
                SqlCommand cmd = con.CreateCommand();
                cmd.CommandText = "insert Person(titleId,fname,lname) values(@titleId,@fname,@lname)";
                con.Open();

                System.Transactions.TransactionOptions trOptions = new System.Transactions.TransactionOptions();
                trOptions.IsolationLevel = System.Transactions.IsolationLevel.ReadCommitted;
                trOptions.Timeout = new TimeSpan(0, 0, 15);
                using (System.Transactions.TransactionScope ts = new System.Transactions.TransactionScope(System.Transactions.TransactionScopeOption.Required, trOptions))
                {
                    try
                    {
                        foreach (DataRow row in this.dt1.Rows)
                        {

                            int titleId = int.Parse(row["titleId"].ToString()); // cause error
                            string fname = row["fname"].ToString();
                            string lname = row["lname"].ToString();

                            if (cmd.Parameters.Count > 0)
                                cmd.Parameters.Clear();

                            cmd.Parameters.AddWithValue("@titleId", titleId);
                            cmd.Parameters.AddWithValue("@fname", fname);
                            cmd.Parameters.AddWithValue("@lname", lname);
                            cmd.ExecuteNonQuery();

                        }
                        con.Close();
                        ts.Complete();
                    }
                    catch (Exception ex)
                    {

                    }                    
                }
            }