Fixed Kafka races (#54)

* fixed some race conditions
* speed up of uuid short tests

internal/norace.go

@@ -0,0 +1,5 @@
+// +build !race
+
+package internal
+
+const RaceEnabled = false

internal/race.go

@@ -0,0 +1,5 @@
+// +build race
+
+package internal
+
+const RaceEnabled = true

message/infrastructure/kafka/pubsub_test.go

@@ -6,6 +6,8 @@ import (
 	"testing"
 	"time"
 
+	"github.com/ThreeDotsLabs/watermill/internal"
+
 	"github.com/Shopify/sarama"
 
 	"github.com/ThreeDotsLabs/watermill"
@@ -102,7 +104,7 @@ func TestPublishSubscribe(t *testing.T) {
 		Persistent:          true,
 	}
 
-	if testing.Short() {
+	if testing.Short() && !internal.RaceEnabled {
 		// Kafka tests are a bit slow, so let's run only basic test
 		// todo - speed up
 		t.Log("Running only TestPublishSubscribe for Kafka with -short flag")

message/message.go

@@ -60,7 +60,7 @@ const (
 )
 
 // Equals compare, that two messages are equal. Acks/Nacks are not compared.
-func (m Message) Equals(toCompare *Message) bool {
+func (m *Message) Equals(toCompare *Message) bool {
 	if m.UUID != toCompare.UUID {
 		return false
 	}
@@ -173,7 +173,7 @@ func (m *Message) SetContext(ctx context.Context) {
 
 // Copy copies all message without Acks/Nacks.
 // The context is not propagated to the copy.
-func (m Message) Copy() *Message {
+func (m *Message) Copy() *Message {
 	msg := NewMessage(m.UUID, m.Payload)
 	msg.Metadata = m.Metadata
 	return msg

uuid_test.go

@@ -11,6 +11,11 @@ func testuUniqness(t *testing.T, genFunc func() string) {
 	producers := 100
 	uuidsPerProducer := 10000
 
+	if testing.Short() {
+		producers = 10
+		uuidsPerProducer = 1000
+	}
+
 	uuidsCount := producers * uuidsPerProducer
 
 	uuids := make(chan string, uuidsCount)