Add time.Sleep after subscribe to topic

Signed-off-by: Darko Draskovic <darko.draskovic@gmail.com>

pkg/messaging/mqtt/pubsub_test.go

@@ -6,6 +6,7 @@ package mqtt_test
 import (
 	"fmt"
 	"testing"
+	"time"
 
 	"github.com/golang/protobuf/proto"
 	"github.com/mainflux/mainflux/pkg/messaging"
@@ -24,9 +25,10 @@ var (
 	msgChan = make(chan messaging.Message)
 )
 
-func TestSubscribe(t *testing.T) {
+func TestPubsub(t *testing.T) {
 	err := subscriber.Subscribe(topic, handler)
 	require.Nil(t, err, fmt.Sprintf("got unexpected error: %s", err))
+	time.Sleep(time.Second * 10)
 
 	cases := []struct {
 		desc     string
@@ -69,6 +71,7 @@ func TestSubscribe(t *testing.T) {
 		require.Nil(t, err, fmt.Sprintf("got unexpected error: %s", err))
 
 		receivedMsg := <-msgChan
+		// _ = receivedMsg
 		assert.Equal(t, expectedMsg, receivedMsg, fmt.Sprintf("%s: expected %+v got %+v\n", tc.desc, expectedMsg, receivedMsg))
 	}
 }

pkg/messaging/mqtt/setup_test.go

@@ -41,7 +41,6 @@ func TestMain(m *testing.M) {
 		log.Fatalf("Could not start container: %s", err)
 	}
 	log.Println("VerneMQ container created")
-
 	handleInterrupt(pool, container)
 
 	address := fmt.Sprintf("%s:%s", "localhost", container.GetPort("1883/tcp"))