fix test case error

Signed-off-by: axfor <aixiaoxiang2009@hotmail.com>
jaegertracing · Apr 22, 2023 · 47430ea · 47430ea
1 parent a8e3274
commit 47430ea
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/cmd/ingester/app/consumer/consumer.go b/cmd/ingester/app/consumer/consumer.go
@@ -105,7 +105,7 @@ func (c *Consumer) Start() {
 }
 
 // Start begins consuming messages in a go routine and consumer is running
-func (c *Consumer) StartAndReady() {
+func (c *Consumer) StartWithReady() {
 	c.Start()
 	c.consumerReady.waitReady()
 }

diff --git a/cmd/ingester/app/consumer/consumer_test.go b/cmd/ingester/app/consumer/consumer_test.go
@@ -171,7 +171,7 @@ func TestGroupConsumer(t *testing.T) {
 	spanWriter.consumer = consumer
 	spanWriter.t = t
 
-	consumer.StartAndReady()
+	consumer.StartWithReady()
 
 	t.Log("Consumer is ready and wait message")
 

diff --git a/plugin/storage/integration/kafka_test.go b/plugin/storage/integration/kafka_test.go
@@ -98,7 +98,7 @@ func (s *KafkaIntegrationTestSuite) initialize() error {
 		return err
 	}
 	// start consume and wait consumer running
-	spanConsumer.StartAndReady()
+	spanConsumer.StartWithReady()
 
 	s.SpanWriter = spanWriter
 	s.SpanReader = &ingester{traceStore}