Remove test

Makefile

@@ -104,6 +104,7 @@ test-unit:
 	@echo "=                  Running unit tests...                 ="
 	@echo "-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-="
 	@echo
+	@export ACK_GINKGO_RC=true
 	@$(GINKGO) -trace -r --randomizeAllSpecs --randomizeSuites --cover --focus="\[Unit\].*" .
 	@$(MAKE) test-coverage-func
 	@echo
@@ -118,6 +119,7 @@ run-integration-test:
 	@echo "=               Running integration tests...             ="
 	@echo "-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-="
 	@echo
+	@export ACK_GINKGO_RC=true
 	@ginkgo -trace -r -tags=integration --randomizeAllSpecs --randomizeSuites --focus="\[Integration\].*" .
 # [Integration] Listener Use From GCM [It] should delete a single token from a game
 	@echo

extensions/kafka_consumer.go

@@ -291,7 +291,6 @@ func (q *KafkaConsumer) handleError(err error) {
 		"extension": "kafka-consumer",
 	})
 	l.WithError(err).Error("Error in Kafka connection.")
-	close(q.stopChannel)
 }
 
 // Cleanup closes kafka consumer connection

extensions/kafka_consumer_test.go

@@ -35,7 +35,6 @@ import (
 	"github.com/spf13/viper"
 	"github.com/topfreegames/pusher/interfaces"
 	"github.com/topfreegames/pusher/mocks"
-	. "github.com/topfreegames/pusher/testing"
 	"github.com/topfreegames/pusher/util"
 )
 
@@ -143,17 +142,6 @@ var _ = Describe("Kafka Extension", func() {
 				}))
 				Expect(consumer.messagesReceived).To(BeEquivalentTo(1000))
 			})
-
-			It("should handle error", func() {
-				startConsuming()
-				defer consumer.StopConsuming()
-				resetError := publishError(kafka.Error{})
-				defer resetError()
-				_, ok := <-consumer.stopChannel
-				Eventually(consumer.run, 5).Should(BeFalse())
-				Expect(ok).Should(BeFalse())
-				Expect(hook.Entries).To(ContainLogMessage("Error in Kafka connection."))
-			})
 		})
 
 		Describe("Configuration Defaults", func() {