| 
														
															@@ -46,8 +46,8 @@ public class MessageCallbackProducer { 
														 | 
													
												
											
												
													
														| 
														 | 
														
															             log.info("MessageCallbackProducer sendMessage = {}", message); 
														 | 
														
														 | 
														
															             log.info("MessageCallbackProducer sendMessage = {}", message); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															             producer.send(message); 
														 | 
														
														 | 
														
															             producer.send(message); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         } catch (Exception e) { 
														 | 
														
														 | 
														
															         } catch (Exception e) { 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-            // TODO: 写阿里云日志 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															-            log.error("MessageCallbackProducer send param = {} error", param, e); 
														 | 
														
														 | 
														
															 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+            log.error("MessageCallbackProducer error send param = {}", param); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															 
														 | 
														
														 | 
														
															+            log.error("MessageCallbackProducer error", e); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															             //重试 
														 | 
														
														 | 
														
															             //重试 
														 | 
													
												
											
												
													
														| 
														 | 
														
															             retry(message); 
														 | 
														
														 | 
														
															             retry(message); 
														 | 
													
												
											
												
													
														| 
														 | 
														
															         } 
														 | 
														
														 | 
														
															         } 
														 |