Fix race condition

redpanda-data · Apr 11, 2018 · 0baa1da · 0baa1da
1 parent cd82b49
commit 0baa1da
Showing 1 changed file with 0 additions and 5 deletions.
diff --git a/lib/input/reader/mqtt.go b/lib/input/reader/mqtt.go
@@ -136,16 +136,11 @@ func (m *MQTT) msgHandler(c mqtt.Client, msg mqtt.Message) {
 
 // Read attempts to read a new message from an MQTT broker.
 func (m *MQTT) Read() (types.Message, error) {
-	if m.client == nil {
-		return nil, types.ErrNotConnected
-	}
-
 	select {
 	case msg := <-m.msgChan:
 		return types.NewMessage([][]byte{[]byte(msg.Payload())}), nil
 	case <-m.interruptChan:
 	}
-
 	return nil, types.ErrTypeClosed
 }