可以处理Spring AMQP Listener Container的java.net.ConnectException吗？

1 回答

• 0

  你需要的是 Listener Container failedEvent，它被发射为;

  private void logException(Throwable t) {
              if (logger.isDebugEnabled()
                      || !(t instanceof AmqpConnectException  || t instanceof CancelledException)) {
                  logger.warn(
                          " raised exception, processing can restart if the connection factory supports it",
                          t);
              }
              else {
                  logger.warn(" raised exception, processing can restart if the connection factory supports it. "
                          + "Exception summary: " + t);
              }
              publishFailedEvent(" raised exception, attempting restart", false, t);
          }
  

  因此，您可以监听这些事件并在达到某些条件时停止您的应用程序 .

  回复于 2024-04-27T03:01:11+08:00