From 5fd719bd8ade7a654585661f53bf135c77e6f2c7 Mon Sep 17 00:00:00 2001 From: Christoph Strobl Date: Tue, 30 Aug 2016 10:36:14 +0200 Subject: [PATCH] DATAREDIS-548 - Polishing. Added connection starvation test for operations during readonly transaction. Original Pull Request: #214 --- .../JedisTransactionalConnectionStarvationTest.java | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) diff --git a/src/test/java/org/springframework/data/redis/connection/jedis/JedisTransactionalConnectionStarvationTest.java b/src/test/java/org/springframework/data/redis/connection/jedis/JedisTransactionalConnectionStarvationTest.java index 20a6f5583..874fb0118 100644 --- a/src/test/java/org/springframework/data/redis/connection/jedis/JedisTransactionalConnectionStarvationTest.java +++ b/src/test/java/org/springframework/data/redis/connection/jedis/JedisTransactionalConnectionStarvationTest.java @@ -1,5 +1,5 @@ /* - * Copyright 2015 the original author or authors. + * Copyright 2015-2016 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -26,11 +26,13 @@ import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.data.redis.core.ValueOperations; import org.springframework.test.annotation.Rollback; import org.springframework.test.context.ContextConfiguration; +import org.springframework.transaction.annotation.Transactional; import redis.clients.jedis.JedisPoolConfig; /** * @author Thomas Darimont + * @author Christoph Strobl */ @ContextConfiguration(classes = { PooledJedisContextConfiguration.class }) public class JedisTransactionalConnectionStarvationTest extends AbstractTransactionalTestBase { @@ -75,6 +77,15 @@ public class JedisTransactionalConnectionStarvationTest extends AbstractTransact tryOperations(MAX_CONNECTIONS + 1); } + /** + * @see DATAREDIS-548 + */ + @Test + @Transactional(readOnly = true) + public void readonlyTransactionSyncShouldNotExcceedMaxConnections() { + tryOperations(MAX_CONNECTIONS + 1); + } + @Configuration public static class PooledJedisContextConfiguration extends RedisContextConfiguration {