Ready-to-use Mass Emailing Functionality with C#, .NET 2.0, and Microsoft® SQL Server 2005 Service Broker

using System;
using System.Collections;
using System.ComponentModel;
using System.Data;
using System.Diagnostics;
using System.ServiceProcess;
using System.Globalization;
using System.Configuration;
using System.IO;
using System.Configuration.Install;
using SmartMassEmail;
using SmartMassEmail.Providers;
using SmartMassEmail.Entities;
namespace SmartMassEmail.Sql2005.Service
{
	public class Sql2005Service : System.ServiceProcess.ServiceBase
	{
		/// <summary> 
		/// Required designer variable.
		/// </summary>
		private System.ComponentModel.Container components = null;

		public Sql2005Service()
		{
			// This call is required by the Windows.Forms Component Designer.
			InitializeComponent();

			// TODO: Add any initialization after the InitComponent call
		}


		/// <summary>
		/// Runs the service.
		/// </summary>
		private static void Run()
		{
			// instantiate and run service
			ServiceBase.Run(
				new ServiceBase[] { new Sql2005Service() });
		}

		// The main entry point for the process
		static void Main(string[] args)
		{
			string opt = null;
			// check for arguments
			if (args.Length > 0)
			{ 
				opt = args[0];
				if(opt!=null && opt.ToLower()=="/install")
				{
					TransactedInstaller ti= new TransactedInstaller();
					ProjectInstaller pi = new ProjectInstaller();
					ti.Installers.Add(pi);
					String path=String.Format("/assemblypath={0}",
						System.Reflection.Assembly.GetExecutingAssembly().Location);
					String[] cmdline={path};
					InstallContext ctx = new InstallContext("",cmdline);			 
					ti.Context =ctx;				 		
					ti.Install(new Hashtable());
				}
				else if (opt !=null && opt.ToLower()=="/uninstall")
				{
					TransactedInstaller ti=new TransactedInstaller();
					ProjectInstaller mi=new ProjectInstaller();
					ti.Installers.Add(mi);
					String path = String.Format("/assemblypath={0}",
						System.Reflection.Assembly.GetExecutingAssembly().Location);
					String[] cmdline={path};
					InstallContext ctx = new InstallContext("",cmdline);
					ti.Context=ctx;
					ti.Uninstall(null);
			 
				}				
				if(opt==null)  // e.g. ,nothing on the command line
				{
					System.ServiceProcess.ServiceBase[] ServicesToRun;
					ServicesToRun = new System.ServiceProcess.ServiceBase[] { new Sql2005Service() };
					System.ServiceProcess.ServiceBase.Run(ServicesToRun);
				}
			}
			else // no arguments, just run
				Run();
		}


		#region Component Designer generated code
		/// <summary> 
		/// Required method for Designer support - do not modify 
		/// the contents of this method with the code editor.
		/// </summary>
		private void InitializeComponent()
		{
			// 
			// Sql2005Service
			// 
			//this.ServiceName = "SmartMassEmailSql2005Service";
			components = new System.ComponentModel.Container();
			this.ServiceName = "SmartMassEmailSql2005Service";

		}
		#endregion

		/// <summary>
		/// Clean up any resources being used.
		/// </summary>
		protected override void Dispose( bool disposing ) 
		{
			if( disposing )
			{
				if (components != null) 
				{
					components.Dispose();
				}
			}
			base.Dispose( disposing );
		}
		
		JobRunning jRun = JobRunning.Instance();


		/// <summary>
		/// Set things in motion so your service can do its work.
		/// </summary>
		protected override void OnStart(string[] args)
		{
			// TODO: Add code here to start your service.
			jRun = JobRunning.Instance();
			InitializeConfigs();
			InitializeTimer();
			timer.Enabled = true;

		}
 
		/// <summary>
		/// Stop this service.
		/// </summary>
		protected override void OnStop()
		{
			// TODO: Add code here to perform any tear-down necessary to stop your service.
			timer.Enabled = false;
			jRun.IsRunning = false;

			
		}

		

		


		#region Custom Methods
		protected System.Timers.Timer timer;
		protected void InitializeConfigs()
		{
			try
			{
			}
			catch (Exception x)
			{
			}

			
		}
		
		
		protected void InitializeTimer()
		{
			//if (timer == null)
					
			timer = new System.Timers.Timer();
			timer.AutoReset = true;
			timer.Interval = ReadAppSettingInterval();
			timer.Elapsed += new System.Timers.ElapsedEventHandler(timer_Elapsed);
		}

		protected double ReadAppSettingInterval()
		{
			double interval = 60000, tempInterval; //initialize to 1 minutes.
			if (ConfigurationSettings.AppSettings != null && 
				ConfigurationSettings.AppSettings["IntervalMinutes"] != null)
			{
				string intervalMin;
				intervalMin =ConfigurationSettings.AppSettings["IntervalMinutes"];
				if (Double.TryParse(intervalMin, NumberStyles.Any,
					NumberFormatInfo.InvariantInfo, out tempInterval))
					interval = tempInterval * 60000;
			}
			return interval;			
		}

		

		
		private void timer_Elapsed(object source,System.Timers.ElapsedEventArgs e)
		{
			if (!jRun.IsRunning)
			{
				try
				{
					jRun.IsRunning = true;
                    DequeueEmail();
				}
				finally
				{
					jRun.IsRunning = false;
				}
			}
			else
			{
				//jRun.No = jRun.No + 1;
			}

			

		}
        private void DequeueEmail( )
        {
            TList<EmailMessage> list = EmailDeQueue.Recieve();
            EmailDispatch.Dispatch(list);
        }   
		#endregion

	}
}