@Bean @ConditionalOnBean(WebSocketMessageBrokerConfigurationSupport.class) public TracingChannelInterceptor tracingInboundChannelInterceptor( WebSocketMessageBrokerConfigurationSupport config) { TracingChannelInterceptor interceptor = new TracingChannelInterceptor(tracer, Tags.SPAN_KIND_SERVER); config.clientInboundChannel().addInterceptor(interceptor); return interceptor; }
@Bean @ConditionalOnBean(WebSocketMessageBrokerConfigurationSupport.class) public TracingChannelInterceptor tracingOutboundChannelInterceptor( WebSocketMessageBrokerConfigurationSupport config) { TracingChannelInterceptor interceptor = new TracingChannelInterceptor(tracer, Tags.SPAN_KIND_CLIENT); config.clientOutboundChannel().addInterceptor(interceptor); return interceptor; }