SpringCloud/spring-cloud-core-tests
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fixed zipkin samples

Browse Source
This commit is contained in:
Marcin Grzejszczak
2016-01-15 10:11:55 +01:00
parent 918e930aa2
commit 19d96e94b6
1 changed files with 15 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
zipkin/src/main/java/demo/ZipkinApplication.java
View File

@@ -1,27 +1,35 @@
package demo;
import io.zipkin.Span;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.cloud.sleuth.sampler.AlwaysSampler;
import org.springframework.cloud.sleuth.zipkin.ZipkinSpanReporter;
import org.springframework.context.annotation.Bean;
import com.github.kristofa.brave.LoggingSpanCollector;
import com.github.kristofa.brave.SpanCollector;
@SpringBootApplication
public class ZipkinApplication {
private static Logger log = LoggerFactory.getLogger(ZipkinApplication.class);
@Bean
public AlwaysSampler alwaysSampler() {
return new AlwaysSampler();
}
// Use this for debugging (or if there is no Zipkin collector running on port 9410)
// Use this for debugging (or if there is no Zipkin server running on port 9411)
@Bean
@ConditionalOnProperty(value="sample.zipkin.enabled", havingValue="false", matchIfMissing=true)
public SpanCollector spanCollector() {
return new LoggingSpanCollector();
@ConditionalOnProperty(value="sample.zipkin.enabled", havingValue="false")
public ZipkinSpanReporter spanCollector() {
return new ZipkinSpanReporter() {
@Override
public void report(Span span) {
log.info("Reporting span [{}]", span);
}
};
}
public static void main(String[] args) {