We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ecbc388 commit ce677bfCopy full SHA for ce677bf
spring-rabbit/src/main/java/org/springframework/amqp/rabbit/connection/SimpleConnection.java
@@ -23,6 +23,7 @@
23
import org.springframework.amqp.rabbit.support.RabbitExceptionTranslator;
24
import org.springframework.util.ObjectUtils;
25
26
+import com.rabbitmq.client.AlreadyClosedException;
27
import com.rabbitmq.client.BlockedListener;
28
import com.rabbitmq.client.Channel;
29
import com.rabbitmq.client.impl.NetworkConnection;
@@ -76,6 +77,9 @@ public void close() {
76
77
// let the physical close time out if necessary
78
this.delegate.close(this.closeTimeout);
79
}
80
+ catch (AlreadyClosedException e) {
81
+ // Ignore
82
+ }
83
catch (IOException e) {
84
throw RabbitExceptionTranslator.convertRabbitAccessException(e);
85
0 commit comments