From 7d971e9a52fb464f32e3de969bcf857c5ef03013 Mon Sep 17 00:00:00 2001
From: Nikita <abracham.mitchell@gmail.com>
Date: Fri, 20 Nov 2015 17:01:14 +0300
Subject: [PATCH] topic test fixed

---
 src/test/java/org/redisson/RedissonTopicTest.java | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/src/test/java/org/redisson/RedissonTopicTest.java b/src/test/java/org/redisson/RedissonTopicTest.java
index 5bb1f2981..8a667edf1 100644
--- a/src/test/java/org/redisson/RedissonTopicTest.java
+++ b/src/test/java/org/redisson/RedissonTopicTest.java
@@ -2,6 +2,7 @@ package org.redisson;
 
 import java.io.Serializable;
 import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
 
 import org.junit.Assert;
 import org.junit.Test;
@@ -67,14 +68,14 @@ public class RedissonTopicTest {
                 messageRecieved.countDown();
                 Message m = new Message("test");
                 if (!msg.equals(m)) {
-                    topic1.publish(m);
-                    topic2.publish(m);
+                    topic1.publishAsync(m);
+                    topic2.publishAsync(m);
                 }
             }
         });
         topic2.publish(new Message("123"));
 
-        messageRecieved.await();
+        Assert.assertTrue(messageRecieved.await(5, TimeUnit.SECONDS));
 
         redisson1.shutdown();
         redisson2.shutdown();