zipkin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From adrianc...@apache.org
Subject [incubator-zipkin-brave] branch master updated: rename test helper method (#910)
Date Thu, 16 May 2019 19:32:00 GMT
This is an automated email from the ASF dual-hosted git repository.

adriancole pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-zipkin-brave.git


The following commit(s) were added to refs/heads/master by this push:
     new 5398599  rename test helper method (#910)
5398599 is described below

commit 5398599dd8d327dd48a1d86821dea3953fb5d438
Author: Jorg Heymans <jorg.heymans@gmail.com>
AuthorDate: Thu May 16 21:31:56 2019 +0200

    rename test helper method (#910)
---
 .../brave/kafka/streams/ITKafkaStreamsTracing.java | 46 +++++++++++-----------
 1 file changed, 23 insertions(+), 23 deletions(-)

diff --git a/instrumentation/kafka-streams/src/test/java/brave/kafka/streams/ITKafkaStreamsTracing.java
b/instrumentation/kafka-streams/src/test/java/brave/kafka/streams/ITKafkaStreamsTracing.java
index 8a902fc..c5d412b 100644
--- a/instrumentation/kafka-streams/src/test/java/brave/kafka/streams/ITKafkaStreamsTracing.java
+++ b/instrumentation/kafka-streams/src/test/java/brave/kafka/streams/ITKafkaStreamsTracing.java
@@ -100,7 +100,7 @@ public class ITKafkaStreamsTracing {
 
     KafkaStreams streams = buildKafkaStreams(topology);
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     waitForStreamToRun(streams);
@@ -126,7 +126,7 @@ public class ITKafkaStreamsTracing {
     KafkaStreams streams =
         new KafkaStreams(topology, streamsProperties(), kafkaStreamsTracing.kafkaClientSupplier());
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     waitForStreamToRun(streams);
@@ -150,7 +150,7 @@ public class ITKafkaStreamsTracing {
 
     KafkaStreams streams = buildKafkaStreams(topology);
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     consumer = createTracingConsumer(outputTopic);
@@ -194,7 +194,7 @@ public class ITKafkaStreamsTracing {
 
     KafkaStreams streams = buildKafkaStreams(topology);
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     waitForStreamToRun(streams);
@@ -222,7 +222,7 @@ public class ITKafkaStreamsTracing {
 
     KafkaStreams streams = buildKafkaStreams(topology);
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     waitForStreamToRun(streams);
@@ -253,7 +253,7 @@ public class ITKafkaStreamsTracing {
 
     KafkaStreams streams = buildKafkaStreams(topology);
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     waitForStreamToRun(streams);
@@ -283,7 +283,7 @@ public class ITKafkaStreamsTracing {
 
     KafkaStreams streams = buildKafkaStreams(topology);
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     waitForStreamToRun(streams);
@@ -313,7 +313,7 @@ public class ITKafkaStreamsTracing {
 
     KafkaStreams streams = buildKafkaStreams(topology);
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     waitForStreamToRun(streams);
@@ -353,7 +353,7 @@ public class ITKafkaStreamsTracing {
 
     KafkaStreams streams = buildKafkaStreams(topology);
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     waitForStreamToRun(streams);
@@ -383,7 +383,7 @@ public class ITKafkaStreamsTracing {
 
     KafkaStreams streams = buildKafkaStreams(topology);
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     waitForStreamToRun(streams);
@@ -416,7 +416,7 @@ public class ITKafkaStreamsTracing {
 
     KafkaStreams streams = buildKafkaStreams(topology);
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     waitForStreamToRun(streams);
@@ -457,7 +457,7 @@ public class ITKafkaStreamsTracing {
 
     KafkaStreams streams = buildKafkaStreamsWithoutTracing(topology);
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     waitForStreamToRun(streams);
@@ -510,7 +510,7 @@ public class ITKafkaStreamsTracing {
 
     KafkaStreams streams = buildKafkaStreams(topology);
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     waitForStreamToRun(streams);
@@ -567,7 +567,7 @@ public class ITKafkaStreamsTracing {
 
     KafkaStreams streams = buildKafkaStreams(topology);
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     waitForStreamToRun(streams);
@@ -628,7 +628,7 @@ public class ITKafkaStreamsTracing {
 
     KafkaStreams streams = buildKafkaStreamsWithoutTracing(topology);
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     waitForStreamToRun(streams);
@@ -681,7 +681,7 @@ public class ITKafkaStreamsTracing {
 
     KafkaStreams streams = buildKafkaStreams(topology);
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     waitForStreamToRun(streams);
@@ -718,7 +718,7 @@ public class ITKafkaStreamsTracing {
 
     KafkaStreams streams = buildKafkaStreams(topology);
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     waitForStreamToRun(streams);
@@ -755,7 +755,7 @@ public class ITKafkaStreamsTracing {
 
     KafkaStreams streams = buildKafkaStreams(topology);
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     waitForStreamToRun(streams);
@@ -792,7 +792,7 @@ public class ITKafkaStreamsTracing {
 
     KafkaStreams streams = buildKafkaStreams(topology);
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     waitForStreamToRun(streams);
@@ -849,7 +849,7 @@ public class ITKafkaStreamsTracing {
 
     KafkaStreams streams = buildKafkaStreamsWithoutTracing(topology);
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     waitForStreamToRun(streams);
@@ -902,7 +902,7 @@ public class ITKafkaStreamsTracing {
 
     KafkaStreams streams = buildKafkaStreams(topology);
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     waitForStreamToRun(streams);
@@ -959,7 +959,7 @@ public class ITKafkaStreamsTracing {
 
     KafkaStreams streams = buildKafkaStreamsWithoutTracing(topology);
 
-    producer = createTracingProducer();
+    producer = createProducer();
     producer.send(new ProducerRecord<>(inputTopic, TEST_KEY, TEST_VALUE)).get();
 
     waitForStreamToRun(streams);
@@ -1002,7 +1002,7 @@ public class ITKafkaStreamsTracing {
     return new KafkaStreams(topology, properties);
   }
 
-  Producer<String, String> createTracingProducer() {
+  Producer<String, String> createProducer() {
     return kafka.helper().createStringProducer();
   }
 


Mime
View raw message