Add spring-cloud-sleuth-stream

spring-cloud-sleuth-stream/src/main/java/org/springframework/cloud/sleuth/stream/DiscoveryClientHostLocator.java

@@ -0,0 +1,57 @@
+/*
+ * Copyright 2015 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.sleuth.stream;
+
+import java.net.InetAddress;
+
+import org.springframework.cloud.client.ServiceInstance;
+import org.springframework.cloud.client.discovery.DiscoveryClient;
+import org.springframework.cloud.sleuth.Span;
+
+/**
+ * An {@link HostLocator} that tries to find local service information from a
+ * {@link DiscoveryClient}.
+ *
+ * @author Dave Syer
+ *
+ */
+public class DiscoveryClientHostLocator implements HostLocator {
+
+	private DiscoveryClient client;
+
+	public DiscoveryClientHostLocator(DiscoveryClient client) {
+		this.client = client;
+	}
+
+	@Override
+	public Host locate(Span span) {
+		ServiceInstance instance = this.client.getLocalServiceInstance();
+		return new Host(instance.getServiceId(), getIpAddress(instance),
+				instance.getPort());
+	}
+
+	private String getIpAddress(ServiceInstance instance) {
+		try {
+			InetAddress address = InetAddress.getByName(instance.getHost());
+			return address.getHostAddress();
+		}
+		catch (Exception e) {
+			return "0.0.0.0";
+		}
+	}
+
+}

spring-cloud-sleuth-stream/src/main/java/org/springframework/cloud/sleuth/stream/Host.java

@@ -0,0 +1,52 @@
+/*
+ * Copyright 2015 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.sleuth.stream;
+
+import java.net.InetAddress;
+import java.net.UnknownHostException;
+import java.nio.ByteBuffer;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+
+/**
+ * @author Dave Syer
+ *
+ */
+@JsonInclude(JsonInclude.Include.NON_NULL)
+@Data
+@AllArgsConstructor
+public class Host {
+
+	private String serviceName;
+	private String address;
+	private Integer port;
+
+	public int getIpv4() {
+		InetAddress inetAddress = null;
+		try {
+			inetAddress = InetAddress.getByName(this.address);
+		}
+		catch (final UnknownHostException e) {
+			throw new IllegalArgumentException(e);
+		}
+		return ByteBuffer.wrap(inetAddress.getAddress()).getInt();
+	}
+
+}

spring-cloud-sleuth-stream/src/main/java/org/springframework/cloud/sleuth/stream/HostLocator.java

@@ -0,0 +1,32 @@
+/*
+ * Copyright 2015 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.sleuth.stream;
+
+import org.springframework.cloud.sleuth.Span;
+
+/**
+ * Strategy for locating a "host" from a Spring Cloud Span (and whatever other
+ * environment properties might be available).
+ *
+ * @author Dave Syer
+ *
+ */
+public interface HostLocator {
+
+	Host locate(Span span);
+
+}

spring-cloud-sleuth-stream/src/main/java/org/springframework/cloud/sleuth/stream/ServerPropertiesHostLocator.java

@@ -0,0 +1,92 @@
+/*
+ * Copyright 2015 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.sleuth.stream;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.autoconfigure.web.ServerProperties;
+import org.springframework.boot.context.embedded.EmbeddedServletContainerInitializedEvent;
+import org.springframework.cloud.sleuth.Span;
+import org.springframework.context.event.EventListener;
+
+/**
+ * @author Dave Syer
+ *
+ */
+public class ServerPropertiesHostLocator implements HostLocator {
+
+	@Value("${spring.application.name:application}")
+	private String appName;
+
+	private ServerProperties serverProperties;
+
+	private Integer port;
+
+	public ServerPropertiesHostLocator(ServerProperties serverProperties) {
+		this.serverProperties = serverProperties;
+	}
+
+	@Override
+	public Host locate(Span span) {
+		String serviceName = getServiceName(span);
+		String address = getAddress();
+		Integer port = getPort();
+		Host ep = new Host(serviceName, address, port);
+		return ep;
+	}
+
+	@EventListener(EmbeddedServletContainerInitializedEvent.class)
+	public void grabPort(EmbeddedServletContainerInitializedEvent event) {
+		this.port = event.getEmbeddedServletContainer().getPort();
+	}
+
+	private Integer getPort() {
+		if (this.port!=null) {
+			return this.port;
+		}
+		Integer port;
+		if (this.serverProperties!=null && this.serverProperties.getPort() != null) {
+			port = this.serverProperties.getPort();
+		}
+		else {
+			port = 8080;
+		}
+		return port;
+	}
+
+	private String getAddress() {
+		String address;
+		if (this.serverProperties!=null && this.serverProperties.getAddress() != null) {
+			address = this.serverProperties.getAddress().getHostAddress();
+		}
+		else {
+			address = "127.0.0.1";
+		}
+		return address;
+	}
+
+	private String getServiceName(Span span) {
+		String serviceName;
+		if (span.getProcessId() != null) {
+			serviceName = span.getProcessId().toLowerCase();
+		}
+		else {
+			serviceName = this.appName;
+		}
+		return serviceName;
+	}
+
+}

spring-cloud-sleuth-stream/src/main/java/org/springframework/cloud/sleuth/stream/SleuthSink.java

@@ -0,0 +1,32 @@
+/*
+ * Copyright 2015 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.sleuth.stream;
+
+import org.springframework.cloud.stream.annotation.Input;
+import org.springframework.messaging.SubscribableChannel;
+
+/**
+ * @author Dave Syer
+ *
+ */
+public interface SleuthSink {
+
+	String INPUT = "sleuth";
+
+	@Input(SleuthSink.INPUT)
+	SubscribableChannel input();
+}

spring-cloud-sleuth-stream/src/main/java/org/springframework/cloud/sleuth/stream/SleuthSource.java

@@ -0,0 +1,33 @@
+/*
+ * Copyright 2015 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.sleuth.stream;
+
+import org.springframework.cloud.stream.annotation.Output;
+import org.springframework.messaging.MessageChannel;
+
+/**
+ * @author Dave Syer
+ *
+ */
+public interface SleuthSource {
+
+	String OUTPUT = "sleuth";
+
+	@Output(SleuthSource.OUTPUT)
+	MessageChannel output();
+
+}

spring-cloud-sleuth-stream/src/main/java/org/springframework/cloud/sleuth/stream/SleuthStreamAutoConfiguration.java

@@ -0,0 +1,107 @@
+/*
+ * Copyright 2013-2015 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.sleuth.stream;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.AutoConfigureBefore;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingClass;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.boot.autoconfigure.web.ServerProperties;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.cloud.client.discovery.DiscoveryClient;
+import org.springframework.cloud.sleuth.Trace;
+import org.springframework.cloud.stream.annotation.EnableBinding;
+import org.springframework.cloud.stream.config.ChannelBindingAutoConfiguration;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.Ordered;
+import org.springframework.integration.config.GlobalChannelInterceptor;
+import org.springframework.integration.support.MessageBuilder;
+import org.springframework.messaging.Message;
+import org.springframework.messaging.MessageChannel;
+import org.springframework.messaging.support.ChannelInterceptor;
+import org.springframework.messaging.support.ChannelInterceptorAdapter;
+
+/**
+ * Autoconfiguration for sending Spans over Spring Cloud Stream. This is for the producer
+ * (via {@link SleuthSource}). A consumer can enable binding to {@link SleuthSink} and
+ * receive the messages coming from the source (they have the same channel name so there
+ * is no additional configuration to do by default).
+ *
+ * @author Dave Syer
+ */
+@Configuration
+@EnableConfigurationProperties(SleuthStreamProperties.class)
+@AutoConfigureBefore(ChannelBindingAutoConfiguration.class)
+@EnableBinding(SleuthSource.class)
+@ConditionalOnProperty(value = "spring.sleuth.stream.enabled", matchIfMissing = true)
+public class SleuthStreamAutoConfiguration {
+
+	@Bean
+	@GlobalChannelInterceptor(patterns = SleuthSource.OUTPUT, order = Ordered.HIGHEST_PRECEDENCE)
+	public ChannelInterceptor zipkinChannelInterceptor() {
+		// don't trace the tracer (suppress spans originating from our own source)
+		return new ChannelInterceptorAdapter() {
+			@Override
+			public Message<?> preSend(Message<?> message, MessageChannel channel) {
+				return MessageBuilder.fromMessage(message)
+						.setHeader(Trace.NOT_SAMPLED_NAME, "").build();
+			}
+		};
+	}
+
+	@Bean
+	public StreamSpanListener sleuthTracer(HostLocator endpointLocator) {
+		return new StreamSpanListener(endpointLocator);
+	}
+
+	@Configuration
+	@ConditionalOnMissingClass("org.springframework.cloud.client.discovery.DiscoveryClient")
+	protected static class DefaultEndpointLocatorConfiguration {
+
+		@Autowired(required = false)
+		private ServerProperties serverProperties;
+
+		@Bean
+		public HostLocator zipkinEndpointLocator() {
+			return new ServerPropertiesHostLocator(this.serverProperties);
+		}
+
+	}
+
+	@Configuration
+	@ConditionalOnClass(DiscoveryClient.class)
+	protected static class DiscoveryClientEndpointLocatorConfiguration {
+
+		@Autowired(required = false)
+		private ServerProperties serverProperties;
+
+		@Autowired(required = false)
+		private DiscoveryClient client;
+
+		@Bean
+		public HostLocator zipkinEndpointLocator() {
+			if (this.client != null) {
+				return new DiscoveryClientHostLocator(this.client);
+			}
+			return new ServerPropertiesHostLocator(this.serverProperties);
+		}
+
+	}
+
+}

spring-cloud-sleuth-stream/src/main/java/org/springframework/cloud/sleuth/stream/SleuthStreamProperties.java

@@ -0,0 +1,30 @@
+/*
+ * Copyright 2013-2015 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.sleuth.stream;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+
+import lombok.Data;
+
+/**
+ * @author Dave Syer
+ */
+@ConfigurationProperties("spring.sleuth.stream")
+@Data
+public class SleuthStreamProperties {
+	private boolean enabled = true;
+}

spring-cloud-sleuth-stream/src/main/java/org/springframework/cloud/sleuth/stream/Spans.java

@@ -0,0 +1,43 @@
+/*
+ * Copyright 2015 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.sleuth.stream;
+
+import java.util.Collections;
+import java.util.List;
+
+import org.springframework.cloud.sleuth.Span;
+
+import com.fasterxml.jackson.annotation.JsonInclude;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+
+/**
+ * Data transfer object for a collection of spans from a given host.
+ *
+ * @author Dave Syer
+ *
+ */
+@JsonInclude(JsonInclude.Include.NON_DEFAULT)
+@Data
+@AllArgsConstructor
+public class Spans {
+
+	private Host host;
+	private List<Span> spans = Collections.emptyList();
+
+}

spring-cloud-sleuth-stream/src/main/java/org/springframework/cloud/sleuth/stream/StreamSpanListener.java

@@ -0,0 +1,115 @@
+/*
+ * Copyright 2013-2015 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.sleuth.stream;
+
+import java.util.ArrayList;
+import java.util.Iterator;
+import java.util.List;
+
+import org.springframework.cloud.sleuth.Span;
+import org.springframework.cloud.sleuth.event.ClientReceivedEvent;
+import org.springframework.cloud.sleuth.event.ClientSentEvent;
+import org.springframework.cloud.sleuth.event.ServerReceivedEvent;
+import org.springframework.cloud.sleuth.event.ServerSentEvent;
+import org.springframework.cloud.sleuth.event.SpanAcquiredEvent;
+import org.springframework.cloud.sleuth.event.SpanReleasedEvent;
+import org.springframework.context.event.EventListener;
+import org.springframework.core.annotation.Order;
+import org.springframework.integration.annotation.InboundChannelAdapter;
+import org.springframework.integration.annotation.MessageEndpoint;
+
+/**
+ * A message source for spans. Also handles RPC flavoured annotations.
+ *
+ * @author Dave Syer
+ */
+@MessageEndpoint
+public class StreamSpanListener {
+
+	public static final String CLIENT_RECV = "cr";
+	public static final String CLIENT_SEND = "cs";
+	public static final String SERVER_RECV = "sr";
+	public static final String SERVER_SEND = "ss";
+
+	private List<Span> queue = new ArrayList<>();
+	private HostLocator endpointLocator;
+
+	public StreamSpanListener(HostLocator endpointLocator) {
+		this.endpointLocator = endpointLocator;
+	}
+
+	public void setQueue(List<Span> queue) {
+		this.queue = queue;
+	}
+
+	@EventListener
+	@Order(0)
+	public void start(SpanAcquiredEvent event) {
+		event.getSpan().addTimelineAnnotation("acquire");
+	}
+
+	@EventListener
+	@Order(0)
+	public void serverReceived(ServerReceivedEvent event) {
+		if (event.getParent() != null && event.getParent().isRemote()) {
+			event.getParent().addTimelineAnnotation(SERVER_RECV);
+		}
+	}
+
+	@EventListener
+	@Order(0)
+	public void clientSend(ClientSentEvent event) {
+		event.getSpan().addTimelineAnnotation(CLIENT_SEND);
+	}
+
+	@EventListener
+	@Order(0)
+	public void clientReceive(ClientReceivedEvent event) {
+		event.getSpan().addTimelineAnnotation(CLIENT_RECV);
+	}
+
+	@EventListener
+	@Order(0)
+	public void serverSend(ServerSentEvent event) {
+		if (event.getParent() != null && event.getParent().isRemote()) {
+			event.getParent().addTimelineAnnotation(SERVER_SEND);
+			this.queue.add(event.getParent());
+		}
+	}
+
+	@EventListener
+	@Order(0)
+	public void release(SpanReleasedEvent event) {
+		event.getSpan().addTimelineAnnotation("release");
+		this.queue.add(event.getSpan());
+	}
+
+	@InboundChannelAdapter(value = SleuthSource.OUTPUT)
+	public Spans poll() {
+		List<Span> result = new ArrayList<>(this.queue);
+		this.queue.clear();
+		for (Iterator<Span> iterator = result.iterator(); iterator.hasNext();) {
+			Span span = iterator.next();
+			if (span.getName().equals("message/zipkin")) {
+				iterator.remove();
+			}
+		}
+		return result.isEmpty() ? null
+				: new Spans(this.endpointLocator.locate(result.get(0)), result);
+	}
+
+}

spring-cloud-sleuth-stream/src/main/resources/META-INF/spring.factories

@@ -0,0 +1,3 @@
+# Auto Configuration
+org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
+org.springframework.cloud.sleuth.stream.SleuthStreamAutoConfiguration

spring-cloud-sleuth-stream/src/test/java/org/springframework/cloud/sleuth/stream/StreamSpanListenerTests.java

@@ -0,0 +1,124 @@
+/*
+ * Copyright 2015 the original author or authors.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.springframework.cloud.sleuth.stream;
+
+import static org.junit.Assert.assertEquals;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import javax.annotation.PostConstruct;
+
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.PropertyPlaceholderAutoConfiguration;
+import org.springframework.boot.test.SpringApplicationConfiguration;
+import org.springframework.cloud.sleuth.MilliSpan;
+import org.springframework.cloud.sleuth.Sampler;
+import org.springframework.cloud.sleuth.Span;
+import org.springframework.cloud.sleuth.Trace;
+import org.springframework.cloud.sleuth.TraceScope;
+import org.springframework.cloud.sleuth.autoconfig.TraceAutoConfiguration;
+import org.springframework.cloud.sleuth.event.ClientReceivedEvent;
+import org.springframework.cloud.sleuth.event.ClientSentEvent;
+import org.springframework.cloud.sleuth.event.ServerReceivedEvent;
+import org.springframework.cloud.sleuth.event.ServerSentEvent;
+import org.springframework.cloud.sleuth.sampler.AlwaysSampler;
+import org.springframework.cloud.sleuth.stream.SleuthStreamAutoConfiguration;
+import org.springframework.cloud.sleuth.stream.StreamSpanListener;
+import org.springframework.cloud.sleuth.stream.StreamSpanListenerTests.TestConfiguration;
+import org.springframework.cloud.stream.binder.local.config.LocalBinderAutoConfiguration;
+import org.springframework.cloud.stream.config.ChannelBindingAutoConfiguration;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.context.annotation.Import;
+import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
+
+/**
+ * @author Dave Syer
+ *
+ */
+@SpringApplicationConfiguration(classes = TestConfiguration.class)
+@RunWith(SpringJUnit4ClassRunner.class)
+public class StreamSpanListenerTests {
+
+	@Autowired
+	private Trace trace;
+
+	@Autowired
+	private ApplicationContext application;
+
+	@Autowired
+	private ZipkinTestConfiguration test;
+
+	@PostConstruct
+	public void init() {
+		this.test.spans.clear();
+	}
+
+	@Test
+	public void acquireAndRelease() {
+		TraceScope context = this.trace.startSpan("foo");
+		context.close();
+		assertEquals(1, this.test.spans.size());
+	}
+
+	@Test
+	public void rpcAnnotations() {
+		Span parent = MilliSpan.builder().traceId("xxxx").name("parent").remote(true)
+				.build();
+		TraceScope context = this.trace.startSpan("child", parent);
+		this.application.publishEvent(new ClientSentEvent(this, context.getSpan()));
+		this.application
+				.publishEvent(new ServerReceivedEvent(this, parent, context.getSpan()));
+		this.application
+				.publishEvent(new ServerSentEvent(this, parent, context.getSpan()));
+		this.application.publishEvent(new ClientReceivedEvent(this, context.getSpan()));
+		context.close();
+		assertEquals(2, this.test.spans.size());
+	}
+
+	@Configuration
+	@Import({ ZipkinTestConfiguration.class, SleuthStreamAutoConfiguration.class,
+			LocalBinderAutoConfiguration.class, ChannelBindingAutoConfiguration.class,
+			TraceAutoConfiguration.class, PropertyPlaceholderAutoConfiguration.class })
+	protected static class TestConfiguration {
+	}
+
+	@Configuration
+	protected static class ZipkinTestConfiguration {
+
+		private List<Span> spans = new ArrayList<>();
+
+		@Autowired
+		StreamSpanListener listener;
+
+		@Bean
+		public Sampler<?> defaultSampler() {
+			return new AlwaysSampler();
+		}
+
+		@PostConstruct
+		public void init() {
+			this.listener.setQueue(this.spans);
+		}
+
+	}
+
+}