Merge pull request #135 from lovoo/hotfix/tester-fix-typo

typo fix in tester code
lovoo · Jun 21, 2018 · 70481ae · 70481ae
2 parents 1f455a9 + ae064e7
commit 70481ae
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/tester/tester.go b/tester/tester.go
@@ -170,19 +170,19 @@ func (km *Tester) ConsumeProto(topic string, key string, msg proto.Message) {
 	if err != nil && km.t != nil {
 		km.t.Errorf("Error marshaling message for consume: %v", err)
 	}
-	km.ConsumeData(topic, key, data)
+	km.consumeData(topic, key, data)
 	km.makeCalls()
 }
 
 // ConsumeString simulates a message with a string payload.
 func (km *Tester) ConsumeString(topic string, key string, msg string) {
-	km.ConsumeData(topic, key, []byte(msg))
+	km.consumeData(topic, key, []byte(msg))
 	km.makeCalls()
 }
 
 // Consume simulates a message with a byte slice payload.
 func (km *Tester) Consume(topic string, key string, msg []byte) {
-	km.ConsumeData(topic, key, msg)
+	km.consumeData(topic, key, msg)
 	km.makeCalls()
 }