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

Changed the remote endpoint for rabbit

Browse Source
This commit is contained in:
Marcin Grzejszczak
2018-03-07 20:42:40 -05:00
parent a6e23231e1
commit 102c3f86b3
2 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/messaging/SleuthMessagingProperties.java
View File

@@ -60,7 +60,7 @@ public class SleuthMessagingProperties {
public static class Messaging {
private boolean enabled;
private String remoteServiceName = "mq-service";
private String remoteServiceName = "rabbitmq";
public boolean isEnabled() {
return this.enabled;

10
spring-cloud-sleuth-core/src/main/java/org/springframework/cloud/sleuth/instrument/messaging/TraceMessagingAutoConfiguration.java
View File

@@ -19,6 +19,7 @@ package org.springframework.cloud.sleuth.instrument.messaging;
import brave.Tracing;
import brave.spring.rabbit.SpringRabbitTracing;
import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.BeansException;
import org.springframework.beans.factory.BeanFactory;
@@ -32,6 +33,7 @@ import org.springframework.boot.context.properties.EnableConfigurationProperties
import org.springframework.cloud.sleuth.autoconfig.TraceAutoConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.util.StringUtils;
/**
* {@link org.springframework.boot.autoconfigure.EnableAutoConfiguration
@@ -54,10 +56,12 @@ public class TraceMessagingAutoConfiguration {
@Bean
@ConditionalOnMissingBean
SpringRabbitTracing springRabbitTracing(Tracing tracing,
SleuthMessagingProperties properties) {
SleuthMessagingProperties properties, ConnectionFactory connectionFactory) {
String remoteServiceName = properties.getMessaging().getRemoteServiceName() +
(StringUtils.hasText(connectionFactory.getVirtualHost()) ?
"-" + connectionFactory.getVirtualHost() : "");
return SpringRabbitTracing.newBuilder(tracing)
.remoteServiceName(properties.getMessaging()
.getRemoteServiceName())
.remoteServiceName(remoteServiceName)
.build();
}