fix

Home/Lib/Action/ListeningFileCreateAction.class.php

@@ -132,12 +132,14 @@ class ListeningFileCreateAction extends Action {
 				}else
 				{
 					DahuaUtil::rlog('redis连接失败');
+					
 				}
 						
 		}catch(Exception $e)
 		{
 			    DahuaUtil::rlog('redis连接异常',$e->getMessage());
-				return;
+				throw new Exception($e->getMessage());
+			
 		}
 						
 				$i=0;
@@ -151,6 +153,7 @@ class ListeningFileCreateAction extends Action {
 			}catch(Exception $e)
 		   {
 					DahuaUtil::rlog('redis取出数据异常'.$e->getMessage());
+					throw new Exception($e->getMessage());
 			}
 		    if(!$res)
 			{
@@ -203,6 +206,7 @@ class ListeningFileCreateAction extends Action {
 						}catch(Exception $e)
 						{
 								DahuaUtil::rlog('打开文件失败'.$e->getMessage());
+							throw new Exception($e->getMessage());
 						}
 							
 						
@@ -232,6 +236,7 @@ class ListeningFileCreateAction extends Action {
 						 }catch(Exception $e)
 						{
 									DahuaUtil::rlog('kafka存取异常'.$e->getMessage());
+								 throw new Exception($e->getMessage());
 						}
 							
 						}
@@ -315,7 +320,8 @@ class ListeningFileCreateAction extends Action {
 			}catch (Exception $e){
 				
 				DahuaUtil::rlog("redis连接异常".$e->getMessage());
-				return;
+				throw new Exception($e->getMessage());
+			
 				
 			 }
 					
@@ -338,7 +344,8 @@ class ListeningFileCreateAction extends Action {
 							      }catch(Exception $e)
 							     {	
 								     DahuaUtil::rlog("redis连接异常".$e->getMessage());
-									  return;
+									  throw new Exception($e->getMessage());
+								
 								//重新连接redis
 								   }