Catch exception when EventSender stopped (#1248)

Z-Beatles · garyrussell · commit 61c044637082 · 2020-09-16T09:36:32.000-04:00
* Catch exception when EventSender stopped

* Add author
diff --git a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/logback/AmqpAppender.java b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/logback/AmqpAppender.java
@@ -97,6 +97,7 @@
  * @author Dominique Villard
  * @author Nicolas Ristock
  * @author Eugene Gusev
+ * @author Wayne Chu
  *
  * @since 1.4
  */
@@ -925,6 +926,9 @@ public void run() {
 			catch (InterruptedException e) {
 				Thread.currentThread().interrupt();
 			}
+			catch (Exception e) {
+				addError("Could not send log message, appender is stopped", e);
+			}
 		}
 
 		private void sendOneEncoderPatternMessage(RabbitTemplate rabbitTemplate, String routingKey) {

Original file line number	Diff line number	Diff line change
`@@ -97,6 +97,7 @@`
`97`	`97`	`* @author Dominique Villard`
`98`	`98`	`* @author Nicolas Ristock`
`99`	`99`	`* @author Eugene Gusev`
	`100`	`+ * @author Wayne Chu`
`100`	`101`	`*`
`101`	`102`	`* @since 1.4`
`102`	`103`	`*/`
`@@ -925,6 +926,9 @@ public void run() {`
`925`	`926`	`catch (InterruptedException e) {`
`926`	`927`	`Thread.currentThread().interrupt();`
`927`	`928`	`}`
	`929`	`+ catch (Exception e) {`
	`930`	`+ addError("Could not send log message, appender is stopped", e);`
	`931`	`+ }`
`928`	`932`	`}`
`929`	`933`
`930`	`934`	`private void sendOneEncoderPatternMessage(RabbitTemplate rabbitTemplate, String routingKey) {`