diff --git a/src/test/java/org/springframework/data/redis/listener/RedisMessageListenerContainerTests.java b/src/test/java/org/springframework/data/redis/listener/RedisMessageListenerContainerTests.java index 94ceee002..e3157d539 100644 --- a/src/test/java/org/springframework/data/redis/listener/RedisMessageListenerContainerTests.java +++ b/src/test/java/org/springframework/data/redis/listener/RedisMessageListenerContainerTests.java @@ -13,7 +13,6 @@ * See the License for the specific language governing permissions and * limitations under the License. */ - package org.springframework.data.redis.listener; import static org.hamcrest.core.Is.*; @@ -37,6 +36,8 @@ import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactor import org.springframework.data.redis.listener.adapter.MessageListenerAdapter; /** + * Unit tests for {@link RedisMessageListenerContainer}. + * * @author Mark Paluch * @author Christoph Strobl */ @@ -58,7 +59,7 @@ public class RedisMessageListenerContainerTests { private Executor executorMock; @Before - public void setUp() throws Exception { + public void setUp() { executorMock = mock(Executor.class); connectionFactoryMock = mock(LettuceConnectionFactory.class); @@ -76,12 +77,11 @@ public class RedisMessageListenerContainerTests { @After public void tearDown() throws Exception { - container.destroy(); } @Test // DATAREDIS-415 - public void interruptAtStart() throws Exception { + public void interruptAtStart() { final Thread main = Thread.currentThread(); @@ -101,7 +101,6 @@ public class RedisMessageListenerContainerTests { // reset the interrupted flag to not destroy the teardown assertThat(Thread.interrupted(), is(true)); - assertThat(container.isRunning(), is(false)); }