Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-3576: Fix NPE in the RedisAvailableTests

Browse Source 
JIRA: https://jira.spring.io/browse/INT-3576
This commit is contained in:
Artem Bilan
2014-12-10 12:49:33 +02:00
committed by Gary Russell
parent 3d43ad1aa9
commit 8ec4ab0355
1 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
spring-integration-redis/src/test/java/org/springframework/integration/redis/rules/RedisAvailableTests.java
View File

@@ -13,8 +13,10 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.springframework.integration.redis.rules;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;
import org.junit.Rule;
@@ -50,10 +52,17 @@ public class RedisAvailableTests {
}
protected void awaitContainerSubscribed(RedisMessageListenerContainer container) throws Exception {
RedisConnection connection = TestUtils.getPropertyValue(container, "subscriptionTask.connection",
RedisConnection.class);
RedisConnection connection = null;
int n = 0;
while (n++ < 100 &&
(connection =
TestUtils.getPropertyValue(container, "subscriptionTask.connection", RedisConnection .class)) == null) {
Thread.sleep(100);
}
assertNotNull("RedisMessageListenerContainer Failed to Connect", connection);
n = 0;
while (n++ < 100 && !connection.isSubscribed()) {
Thread.sleep(100);
}