| 
				
				
					
				
				
				 | 
			
			 | 
			@@ -150,7 +150,7 @@ public class WxCpMessageRouter { | 
		
		
	
		
			
			 | 
			 | 
			
			 | 
			      } else { | 
		
		
	
		
			
			 | 
			 | 
			
			 | 
			        res = rule.service(wxMessage); | 
		
		
	
		
			
			 | 
			 | 
			
			 | 
			        // 在同步操作结束,session访问结束 | 
		
		
	
		
			
			 | 
			 | 
			
			 | 
			        log.trace("End session access after sync operation finish {}", wxMessage.getFromUserName()); | 
		
		
	
		
			
			 | 
			 | 
			
			 | 
			        log.debug("End session access: async=false, sessionId={}", wxMessage.getFromUserName()); | 
		
		
	
		
			
			 | 
			 | 
			
			 | 
			        sessionEndAccess(wxMessage); | 
		
		
	
		
			
			 | 
			 | 
			
			 | 
			      } | 
		
		
	
		
			
			 | 
			 | 
			
			 | 
			    } | 
		
		
	
	
		
			
				| 
				
				
				
					
				
				 | 
			
			 | 
			@@ -162,7 +162,7 @@ public class WxCpMessageRouter { | 
		
		
	
		
			
			 | 
			 | 
			
			 | 
			          for (Future future : futures) { | 
		
		
	
		
			
			 | 
			 | 
			
			 | 
			            try { | 
		
		
	
		
			
			 | 
			 | 
			
			 | 
			              future.get(); | 
		
		
	
		
			
			 | 
			 | 
			
			 | 
			              log.trace("End session access after async operation finish {}", wxMessage.getFromUserName()); | 
		
		
	
		
			
			 | 
			 | 
			
			 | 
			              log.debug("End session access: async=true, sessionId={}", wxMessage.getFromUserName()); | 
		
		
	
		
			
			 | 
			 | 
			
			 | 
			              // 异步操作结束,session访问结束 | 
		
		
	
		
			
			 | 
			 | 
			
			 | 
			              sessionEndAccess(wxMessage); | 
		
		
	
		
			
			 | 
			 | 
			
			 | 
			            } catch (InterruptedException e) { | 
		
		
	
	
		
			
				| 
				
					
				
				
				
				 | 
			
			 | 
			
  |