Add missing @nullable to new method

garyrussell · garyrussell · commit 3ca85b96e650 · 2018-11-22T20:04:06.000-05:00
diff --git a/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/connection/CachingConnectionFactory.java b/spring-rabbit/src/main/java/org/springframework/amqp/rabbit/connection/CachingConnectionFactory.java
@@ -733,6 +733,7 @@ else if (!cachedConnection.isOpen()) {
 		return cachedConnection;
 	}
 
+	@Nullable
 	private ChannelCachingConnectionProxy waitForConnection(ChannelCachingConnectionProxy cachedConnection, long now) {
 		while (cachedConnection == null && System.currentTimeMillis() - now < this.channelCheckoutTimeout) {
 			if (countOpenConnections() >= this.connectionLimit) {

Original file line number	Diff line number	Diff line change
`@@ -733,6 +733,7 @@ else if (!cachedConnection.isOpen()) {`
`733`	`733`	`return cachedConnection;`
`734`	`734`	`}`
`735`	`735`
	`736`	`+ @Nullable`
`736`	`737`	`private ChannelCachingConnectionProxy waitForConnection(ChannelCachingConnectionProxy cachedConnection, long now) {`
`737`	`738`	`while (cachedConnection == null && System.currentTimeMillis() - now < this.channelCheckoutTimeout) {`
`738`	`739`	`if (countOpenConnections() >= this.connectionLimit) {`