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

Fix test so it compiles in Eclipse

Browse Source 
Maybe a JDT bug, but this version is more readable IMO anyway.
This commit is contained in:
Dave Syer
2016-03-11 09:24:55 +00:00
parent f29d75b98a
commit 84c57d9701
1 changed files with 10 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
spring-cloud-sleuth-core/src/test/java/org/springframework/cloud/sleuth/instrument/messaging/websocket/TraceWebSocketAutoConfigurationTest.java
View File

@@ -16,6 +16,8 @@
package org.springframework.cloud.sleuth.instrument.messaging.websocket;
import static org.assertj.core.api.BDDAssertions.then;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
@@ -30,9 +32,6 @@ import org.springframework.web.socket.config.annotation.DelegatingWebSocketMessa
import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
import static java.util.stream.Collectors.toList;
import static org.assertj.core.api.BDDAssertions.then;
/**
* @author Marcin Grzejszczak
*/
@@ -40,24 +39,17 @@ import static org.assertj.core.api.BDDAssertions.then;
@SpringApplicationConfiguration(classes = TraceWebSocketAutoConfigurationTest.Config.class)
public class TraceWebSocketAutoConfigurationTest {
@Autowired DelegatingWebSocketMessageBrokerConfiguration delegatingWebSocketMessageBrokerConfiguration;
@Autowired
DelegatingWebSocketMessageBrokerConfiguration delegatingWebSocketMessageBrokerConfiguration;
@Test
public void should_register_interceptors_for_inbound_and_outbound_channels() {
then(this.delegatingWebSocketMessageBrokerConfiguration
.clientInboundChannel()
.getInterceptors()
.stream()
.map(Object::getClass)
.collect(toList()))
.contains(TraceChannelInterceptor.class);
then(this.delegatingWebSocketMessageBrokerConfiguration
.clientOutboundChannel()
.getInterceptors()
.stream()
.map(Object::getClass)
.collect(toList()))
.contains(TraceChannelInterceptor.class);
then(this.delegatingWebSocketMessageBrokerConfiguration.clientInboundChannel()
.getInterceptors())
.hasAtLeastOneElementOfType(TraceChannelInterceptor.class);
then(this.delegatingWebSocketMessageBrokerConfiguration.clientOutboundChannel()
.getInterceptors())
.hasAtLeastOneElementOfType(TraceChannelInterceptor.class);
}
@EnableAutoConfiguration