From a60b47c7218b446a7e0e9084dc1237af996c0ba6 Mon Sep 17 00:00:00 2001
From: Nikita <abracham.mitchell@gmail.com>
Date: Thu, 16 Jul 2015 15:18:22 +0300
Subject: [PATCH] topic pattern test fixed

---
 .../org/redisson/RedissonTopicPatternTest.java     | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/src/test/java/org/redisson/RedissonTopicPatternTest.java b/src/test/java/org/redisson/RedissonTopicPatternTest.java
index 46a073b1d..b5600996c 100644
--- a/src/test/java/org/redisson/RedissonTopicPatternTest.java
+++ b/src/test/java/org/redisson/RedissonTopicPatternTest.java
@@ -52,7 +52,7 @@ public class RedissonTopicPatternTest {
     public void testUnsubscribe() throws InterruptedException {
         final CountDownLatch messageRecieved = new CountDownLatch(1);
 
-        Redisson redisson = Redisson.create();
+        Redisson redisson = BaseTest.createInstance();
         RTopic<Message> topic1 = redisson.getTopicPattern("topic1.*");
         int listenerId = topic1.addListener(new MessageListener<Message>() {
             @Override
@@ -81,7 +81,7 @@ public class RedissonTopicPatternTest {
     public void testLazyUnsubscribe() throws InterruptedException {
         final CountDownLatch messageRecieved = new CountDownLatch(1);
 
-        Redisson redisson1 = Redisson.create();
+        Redisson redisson1 = BaseTest.createInstance();
         RTopic<Message> topic1 = redisson1.getTopicPattern("topic.*");
         int listenerId = topic1.addListener(new MessageListener<Message>() {
             @Override
@@ -94,7 +94,7 @@ public class RedissonTopicPatternTest {
         topic1.removeListener(listenerId);
         Thread.sleep(1000);
 
-        Redisson redisson2 = Redisson.create();
+        Redisson redisson2 = BaseTest.createInstance();
         RTopic<Message> topic2 = redisson2.getTopicPattern("topic.*");
         topic2.addListener(new MessageListener<Message>() {
             @Override
@@ -118,7 +118,7 @@ public class RedissonTopicPatternTest {
     public void test() throws InterruptedException {
         final CountDownLatch messageRecieved = new CountDownLatch(5);
 
-        Redisson redisson1 = Redisson.create();
+        Redisson redisson1 = BaseTest.createInstance();
         RTopic<Message> topic1 = redisson1.getTopicPattern("topic.*");
         topic1.addListener(new MessageListener<Message>() {
             @Override
@@ -128,7 +128,7 @@ public class RedissonTopicPatternTest {
             }
         });
 
-        Redisson redisson2 = Redisson.create();
+        Redisson redisson2 = BaseTest.createInstance();
         RTopic<Message> topic2 = redisson2.getTopic("topic.t1");
         topic2.addListener(new MessageListener<Message>() {
             @Override
@@ -156,7 +156,7 @@ public class RedissonTopicPatternTest {
 
     @Test
     public void testListenerRemove() throws InterruptedException {
-        Redisson redisson1 = Redisson.create();
+        Redisson redisson1 = BaseTest.createInstance();
         RTopic<Message> topic1 = redisson1.getTopicPattern("topic.*");
         int id = topic1.addListener(new MessageListener<Message>() {
             @Override
@@ -165,7 +165,7 @@ public class RedissonTopicPatternTest {
             }
         });
 
-        Redisson redisson2 = Redisson.create();
+        Redisson redisson2 = BaseTest.createInstance();
         RTopic<Message> topic2 = redisson2.getTopic("topic.t1");
         topic1.removeListener(id);
         topic2.publish(new Message("123"));