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

Fixed failing compilation

Browse Source
This commit is contained in:
Marcin Grzejszczak
2020-12-16 09:17:30 +01:00
parent d7c924e6a0
commit 3cbb3343b4
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
tests/common/src/main/java/org/springframework/cloud/sleuth/instrument/messaging/TraceWebSocketAutoConfigurationTests.java
View File

@@ -23,6 +23,7 @@ import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.messaging.support.AbstractSubscribableChannel;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.web.socket.config.annotation.AbstractWebSocketMessageBrokerConfigurer;
import org.springframework.web.socket.config.annotation.DelegatingWebSocketMessageBrokerConfiguration;
@@ -40,11 +41,17 @@ public abstract class TraceWebSocketAutoConfigurationTests {
@Test
public void should_register_interceptors_for_all_channels() {
BDDAssertions.then(this.delegatingWebSocketMessageBrokerConfiguration.clientInboundChannel().getInterceptors())
AbstractSubscribableChannel inboundChannel = this.delegatingWebSocketMessageBrokerConfiguration
.clientInboundChannel(this.delegatingWebSocketMessageBrokerConfiguration.clientInboundChannelExecutor());
BDDAssertions.then(inboundChannel.getInterceptors())
.hasAtLeastOneElementOfType(TracingChannelInterceptor.class);
BDDAssertions.then(this.delegatingWebSocketMessageBrokerConfiguration.clientOutboundChannel().getInterceptors())
AbstractSubscribableChannel outboundChannel = this.delegatingWebSocketMessageBrokerConfiguration
.clientOutboundChannel(this.delegatingWebSocketMessageBrokerConfiguration.clientOutboundChannelExecutor());
BDDAssertions.then(outboundChannel.getInterceptors())
.hasAtLeastOneElementOfType(TracingChannelInterceptor.class);
BDDAssertions.then(this.delegatingWebSocketMessageBrokerConfiguration.brokerChannel().getInterceptors())
BDDAssertions.then(this.delegatingWebSocketMessageBrokerConfiguration
.brokerChannel(inboundChannel, outboundChannel, this.delegatingWebSocketMessageBrokerConfiguration.brokerChannelExecutor(inboundChannel, outboundChannel))
.getInterceptors())
.hasAtLeastOneElementOfType(TracingChannelInterceptor.class);
}