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

Moving HttpTraceRepository to HttpExchangeRepository

Browse Source
This commit is contained in:
Ryan Baxter
2022-11-03 10:35:32 -04:00
parent 808343ebc3
commit 4cd38623e8
2 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-cloud-bus/src/main/java/org/springframework/cloud/bus/BusAutoConfiguration.java
View File

@@ -19,7 +19,7 @@ package org.springframework.cloud.bus;
import org.springframework.beans.factory.ObjectProvider;
import org.springframework.boot.actuate.autoconfigure.endpoint.condition.ConditionalOnAvailableEndpoint;
import org.springframework.boot.actuate.endpoint.annotation.Endpoint;
import org.springframework.boot.actuate.trace.http.HttpTraceRepository;
import org.springframework.boot.actuate.web.exchanges.HttpExchangeRepository;
import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
@@ -68,13 +68,13 @@ public class BusAutoConfiguration {
@Configuration(proxyBeanMethods = false)
@ConditionalOnClass({ Endpoint.class })
@ConditionalOnBean(HttpTraceRepository.class)
@ConditionalOnBean(HttpExchangeRepository.class)
@ConditionalOnProperty(BusProperties.PREFIX + ".trace.enabled")
protected static class BusAckTraceConfiguration {
@Bean
@ConditionalOnMissingBean
public TraceListener ackTraceListener(HttpTraceRepository repository) {
public TraceListener ackTraceListener(HttpExchangeRepository repository) {
return new TraceListener(repository);
}

8
spring-cloud-bus/src/main/java/org/springframework/cloud/bus/event/TraceListener.java
View File

@@ -22,12 +22,12 @@ import java.util.Map;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.boot.actuate.trace.http.HttpTraceRepository;
import org.springframework.boot.actuate.web.exchanges.HttpExchangeRepository;
import org.springframework.context.event.EventListener;
/**
* A listener for sends and acks of remote application events. Inserts a record for each
* signal in the {@link HttpTraceRepository}.
* signal in the {@link HttpExchangeRepository}.
*
* @author Dave Syer
*/
@@ -35,9 +35,9 @@ public class TraceListener {
private static Log log = LogFactory.getLog(TraceListener.class);
private HttpTraceRepository repository;
private HttpExchangeRepository repository;
public TraceListener(HttpTraceRepository repository) {
public TraceListener(HttpExchangeRepository repository) {
this.repository = repository;
}