public static List<Appointment> GetAppByLegId(long legId)
        {
            DBConnManager manager = DBConnManager.GetDBConnManager();
            IDbConnection conn = manager.GetConnection();
            List<Appointment> apps = null;
            DebugMessageService ds = DebugMessageService.GetService();

            try
            {
                OleDbDataReader dr = null;

                using (dr = DBUtils.ExecSQL(conn as OleDbConnection, null, "exec sq_WSGetAppByLegId ?", new object[] { legId }))
                {
                    apps = ParseDBResponce_Apps(dr);
                }
            }
            finally
            {
                manager.FreeConnection(conn);
            }
            return apps;
        }

...

        public IDbConnection GetConnection()
        {
            OleDbConnection conn = null;
            try
            {
                conn = new OleDbConnection(GetConnectionString());
            }
            catch (Exception e)
            {
                return null;
            }
            return conn;
        }

        public static OleDbDataReader ExecSQL(OleDbConnection conn, OleDbTransaction trans, string sql, object[] parameters)
        {
            OleDbCommand oleCmd = new OleDbCommand(sql);
            oleCmd.CommandTimeout = 300;
            oleCmd.Connection = conn;
            BuildParameters(oleCmd, parameters);
            if (conn.State == ConnectionState.Closed)
                conn.Open();
            if (trans != null)
                oleCmd.Transaction = trans;
            return oleCmd.ExecuteReader(CommandBehavior.Default);
        }

        public String NotifyLegStateChanged(long legId, ILog logger)
        {
            String responce = null;

            try
            {
                String brokerEndpoint = ConfigService.GetInstance().GetBrokerEndpoint();
                if (String.IsNullOrWhiteSpace(brokerEndpoint))
                {
                    throw new Exception("Broker Endpoint is empty");
                }

                List<Appointment> apps = DALApps.GetAppByLegId(legId);
                
                if (apps == null || apps.Count == 0)
                    throw new Exception("App for Leg with ID " + legId.ToString() + " not found");

                if (!apps.Any(x => x.Legs.Any(l => l.AppLegId == legId)))
                    throw new Exception("App Leg with ID " + legId.ToString() + " not found");

                Appointment app = apps.First(x => x.Legs.Any(l => l.AppLegId == legId));
                Models.AmbDispatch.Leg leg = app.Legs.First(l => l.AppLegId == legId);
                if (!apps[0].AppIsForToday())
                    return null;
                
                responce = DALBroker.GetInstance().NotifyLegUpdated(app, leg);
            }
            catch (Exception e)
            {
                responce = "Exception in DAL.NotifyAppStateChanged: " + e.Message;
            }
            
            return responce;
        }