File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
spring-rabbit/src/main/java/org/springframework/amqp/rabbit/connection Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change @@ -695,7 +695,7 @@ private Connection connectionFromCache() {
695
695
ChannelCachingConnectionProxy cachedConnection = findIdleConnection ();
696
696
long now = System .currentTimeMillis ();
697
697
if (cachedConnection == null ) {
698
- cachedConnection = waitForConnection (cachedConnection , now );
698
+ cachedConnection = waitForConnection (now );
699
699
}
700
700
if (cachedConnection == null ) {
701
701
if (countOpenConnections () >= this .connectionLimit
@@ -734,7 +734,8 @@ else if (!cachedConnection.isOpen()) {
734
734
}
735
735
736
736
@ Nullable
737
- private ChannelCachingConnectionProxy waitForConnection (ChannelCachingConnectionProxy cachedConnection , long now ) {
737
+ private ChannelCachingConnectionProxy waitForConnection (long now ) {
738
+ ChannelCachingConnectionProxy cachedConnection = null ;
738
739
while (cachedConnection == null && System .currentTimeMillis () - now < this .channelCheckoutTimeout ) {
739
740
if (countOpenConnections () >= this .connectionLimit ) {
740
741
try {
You can’t perform that action at this time.
0 commit comments