{"action":"created","issue":{"url":"https://api.github.com/repos/spring-cloud/spring-cloud-sleuth/issues/646","repository_url":"https://api.github.com/repos/spring-cloud/spring-cloud-sleuth","labels_url":"https://api.github.com/repos/spring-cloud/spring-cloud-sleuth/issues/646/labels{/name}","comments_url":"https://api.github.com/repos/spring-cloud/spring-cloud-sleuth/issues/646/comments","events_url":"https://api.github.com/repos/spring-cloud/spring-cloud-sleuth/issues/646/events","html_url":"https://github.com/spring-cloud/spring-cloud-sleuth/issues/646","id":243976715,"number":646,"title":"Sleuth + Reactor. SpanSubscriber cannot be cast to reactor.core.Fuseable$QueueSubscription","user":{"login":"msymonov","id":25516216,"avatar_url":"https://avatars1.githubusercontent.com/u/25516216?v=4","gravatar_id":"","url":"https://api.github.com/users/msymonov","html_url":"https://github.com/msymonov","followers_url":"https://api.github.com/users/msymonov/followers","following_url":"https://api.github.com/users/msymonov/following{/other_user}","gists_url":"https://api.github.com/users/msymonov/gists{/gist_id}","starred_url":"https://api.github.com/users/msymonov/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/msymonov/subscriptions","organizations_url":"https://api.github.com/users/msymonov/orgs","repos_url":"https://api.github.com/users/msymonov/repos","events_url":"https://api.github.com/users/msymonov/events{/privacy}","received_events_url":"https://api.github.com/users/msymonov/received_events","type":"User","site_admin":false},"labels":[{"id":184100568,"url":"https://api.github.com/repos/spring-cloud/spring-cloud-sleuth/labels/bug","name":"bug","color":"fc2929","default":true}],"state":"closed","locked":false,"assignee":null,"assignees":[],"milestone":{"url":"https://api.github.com/repos/spring-cloud/spring-cloud-sleuth/milestones/33","html_url":"https://github.com/spring-cloud/spring-cloud-sleuth/milestone/33","labels_url":"https://api.github.com/repos/spring-cloud/spring-cloud-sleuth/milestones/33/labels","id":2723081,"number":33,"title":"1.3.0.RC1","description":"","creator":{"login":"marcingrzejszczak","id":3297437,"avatar_url":"https://avatars0.githubusercontent.com/u/3297437?v=4","gravatar_id":"","url":"https://api.github.com/users/marcingrzejszczak","html_url":"https://github.com/marcingrzejszczak","followers_url":"https://api.github.com/users/marcingrzejszczak/followers","following_url":"https://api.github.com/users/marcingrzejszczak/following{/other_user}","gists_url":"https://api.github.com/users/marcingrzejszczak/gists{/gist_id}","starred_url":"https://api.github.com/users/marcingrzejszczak/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/marcingrzejszczak/subscriptions","organizations_url":"https://api.github.com/users/marcingrzejszczak/orgs","repos_url":"https://api.github.com/users/marcingrzejszczak/repos","events_url":"https://api.github.com/users/marcingrzejszczak/events{/privacy}","received_events_url":"https://api.github.com/users/marcingrzejszczak/received_events","type":"User","site_admin":false},"open_issues":0,"closed_issues":20,"state":"closed","created_at":"2017-08-25T10:53:02Z","updated_at":"2017-10-24T08:48:07Z","due_on":null,"closed_at":"2017-10-24T08:48:07Z"},"comments":2,"created_at":"2017-07-19T09:24:35Z","updated_at":"2018-02-15T09:21:02Z","closed_at":"2017-07-20T08:29:48Z","author_association":"NONE","body":"We use Sleuth and Spring Reactor on our project. Official support hasn't been added yet, however i can see that some changes were done on both sides.\r\nI have tried using Reactor `Bismuth-M3(3.1.0-SNAPSHOT)` and latest `Sleuth(1.3.0.BUILD-SNAPSHOT)` which has now 'spring-cloud-sleuth-reactor' module.\r\n\r\nSee the stacktrace:\r\n\r\n```\r\njava.lang.ClassCastException: org.springframework.cloud.sleuth.instrument.reactor.SpanSubscriber cannot be cast to reactor.core.Fuseable$QueueSubscription\r\n\tat reactor.core.publisher.FluxPeekFuseable$PeekFuseableSubscriber.onSubscribe(FluxPeekFuseable.java:172)\r\n\tat org.springframework.cloud.sleuth.instrument.reactor.SpanSubscriber.onSubscribe(SpanSubscriber.java:60)\r\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:58)\r\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:2769)\r\n\tat reactor.core.publisher.FluxFlatMap.trySubscribeScalarMap(FluxFlatMap.java:169)\r\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:53)\r\n\tat reactor.core.publisher.MonoPeekFuseable.subscribe(MonoPeekFuseable.java:74)\r\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\r\n\tat reactor.core.publisher.Mono.subscribe(Mono.java:2769)\r\n\tat reactor.core.publisher.MonoWhen$WhenCoordinator.subscribe(MonoWhen.java:177)\r\n\tat reactor.core.publisher.MonoWhen.subscribe(MonoWhen.java:127)\r\n\tat reactor.core.publisher.MonoFlatMap.subscribe(MonoFlatMap.java:60)\r\n\tat reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:148)\r\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1010)\r\n\tat reactor.core.publisher.MonoFlatMap$FlatMapMain.onNext(MonoFlatMap.java:142)\r\n\tat reactor.core.publisher.FluxMapFuseable$MapFuseableSubscriber.onNext(FluxMapFuseable.java:115)\r\n\tat reactor.core.publisher.Operators$MonoSubscriber.complete(Operators.java:1010)\r\n\tat reactor.core.publisher.MonoIgnoreThen$ThenAcceptInner.onNext(MonoIgnoreThen.java:288)\r\n\tat reactor.core.publisher.FluxPeek$PeekSubscriber.onNext(FluxPeek.java:185)\r\n\tat reactor.core.publisher.MonoNext$NextSubscriber.onNext(MonoNext.java:76)\r\n\tat rx.internal.reactivestreams.SingleAsPublisher$SingleAsPublisherSubscriber.onSuccess(SingleAsPublisher.java:86)\r\n\tat rx.Single$18.onNext(Single.java:1911)\r\n\tat rx.observers.SafeSubscriber.onNext(SafeSubscriber.java:134)\r\n\tat rx.internal.producers.SingleDelayedProducer.emit(SingleDelayedProducer.java:102)\r\n\tat rx.internal.producers.SingleDelayedProducer.setValue(SingleDelayedProducer.java:85)\r\n\tat rx.Single$1$1.onSuccess(Single.java:80)\r\n\tat rx.internal.operators.OnSubscribeSingle$1.onCompleted(OnSubscribeSingle.java:55)\r\n\tat rx.observers.Subscribers$5.onCompleted(Subscribers.java:225)\r\n\tat rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onCompleted(OnSubscribeDoOnEach.java:70)\r\n\tat rx.observers.Subscribers$5.onCompleted(Subscribers.java:225)\r\n\tat rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onCompleted(OnSubscribeDoOnEach.java:70)\r\n\tat rx.internal.operators.OnSubscribeMap$MapSubscriber.onCompleted(OnSubscribeMap.java:97)\r\n\tat rx.observers.Subscribers$5.onCompleted(Subscribers.java:225)\r\n\tat rx.observers.Subscribers$5.onCompleted(Subscribers.java:225)\r\n\tat rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onCompleted(OnSubscribeDoOnEach.java:70)\r\n\tat rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onCompleted(OnSubscribeDoOnEach.java:70)\r\n\tat rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onCompleted(OnSubscribeDoOnEach.java:70)\r\n\tat rx.internal.operators.OperatorOnErrorResumeNextViaFunction$4.onCompleted(OperatorOnErrorResumeNextViaFunction.java:101)\r\n\tat rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onCompleted(OnSubscribeDoOnEach.java:70)\r\n\tat rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onCompleted(OnSubscribeDoOnEach.java:70)\r\n\tat com.netflix.hystrix.AbstractCommand$HystrixObservableTimeoutOperator$2.onCompleted(AbstractCommand.java:1185)\r\n\tat rx.internal.operators.OperatorSubscribeOn$1$1.onCompleted(OperatorSubscribeOn.java:68)\r\n\tat rx.observers.Subscribers$5.onCompleted(Subscribers.java:225)\r\n\tat rx.internal.operators.OnSubscribeDoOnEach$DoOnEachSubscriber.onCompleted(OnSubscribeDoOnEach.java:70)\r\n\tat rx.observers.Subscribers$5.onCompleted(Subscribers.java:225)\r\n\tat com.netflix.hystrix.AbstractCommand$DeprecatedOnRunHookApplication$1.onCompleted(AbstractCommand.java:1423)\r\n\tat com.netflix.hystrix.AbstractCommand$ExecutionHookApplication$1.onCompleted(AbstractCommand.java:1356)\r\n\tat rx.observers.Subscribers$5.onCompleted(Subscribers.java:225)\r\n\tat rx.observers.Subscribers$5.onCompleted(Subscribers.java:225)\r\n\tat rx.internal.util.ScalarSynchronousObservable$WeakSingleProducer.request(ScalarSynchronousObservable.java:285)\r\n\tat rx.internal.operators.OperatorSubscribeOn$1$1$1.request(OperatorSubscribeOn.java:80)\r\n\tat rx.Subscriber.setProducer(Subscriber.java:209)\r\n\tat rx.internal.operators.OperatorSubscribeOn$1$1.setProducer(OperatorSubscribeOn.java:76)\r\n\tat rx.Subscriber.setProducer(Subscriber.java:205)\r\n\tat rx.Subscriber.setProducer(Subscriber.java:205)\r\n\tat rx.Subscriber.setProducer(Subscriber.java:205)\r\n\tat rx.Subscriber.setProducer(Subscriber.java:205)\r\n\tat rx.Subscriber.setProducer(Subscriber.java:205)\r\n\tat rx.Subscriber.setProducer(Subscriber.java:205)\r\n\tat rx.Subscriber.setProducer(Subscriber.java:205)\r\n\tat rx.internal.util.ScalarSynchronousObservable$JustOnSubscribe.call(ScalarSynchronousObservable.java:138)\r\n\tat rx.internal.util.ScalarSynchronousObservable$JustOnSubscribe.call(ScalarSynchronousObservable.java:129)\r\n\tat rx.Observable.unsafeSubscribe(Observable.java:10211)\r\n\tat rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java:51)\r\n\tat rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java:35)\r\n\tat rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)\r\n\tat rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)\r\n\tat rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)\r\n\tat rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)\r\n\tat rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)\r\n\tat rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)\r\n\tat rx.Observable.unsafeSubscribe(Observable.java:10211)\r\n\tat rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java:51)\r\n\tat rx.internal.operators.OnSubscribeDefer.call(OnSubscribeDefer.java:35)\r\n\tat rx.Observable.unsafeSubscribe(Observable.java:10211)\r\n\tat rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:41)\r\n\tat rx.internal.operators.OnSubscribeDoOnEach.call(OnSubscribeDoOnEach.java:30)\r\n\tat rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:48)\r\n\tat rx.internal.operators.OnSubscribeLift.call(OnSubscribeLift.java:30)\r\n\tat rx.Observable.unsafeSubscribe(Observable.java:10211)\r\n\tat rx.internal.operators.OperatorSubscribeOn$1.call(OperatorSubscribeOn.java:94)\r\n\tat com.netflix.hystrix.strategy.concurrency.HystrixContexSchedulerAction$1.call(HystrixContexSchedulerAction.java:56)\r\n\tat com.netflix.hystrix.strategy.concurrency.HystrixContexSchedulerAction$1.call(HystrixContexSchedulerAction.java:47)\r\n\tat org.springframework.cloud.sleuth.instrument.hystrix.SleuthHystrixConcurrencyStrategy$HystrixTraceCallable.call(SleuthHystrixConcurrencyStrategy.java:154)\r\n\tat com.netflix.hystrix.strategy.concurrency.HystrixContexSchedulerAction.call(HystrixContexSchedulerAction.java:69)\r\n\tat rx.internal.schedulers.ScheduledAction.run(ScheduledAction.java:55)\r\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\r\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\r\n```"},"comment":{"url":"https://api.github.com/repos/spring-cloud/spring-cloud-sleuth/issues/comments/365868635","html_url":"https://github.com/spring-cloud/spring-cloud-sleuth/issues/646#issuecomment-365868635","issue_url":"https://api.github.com/repos/spring-cloud/spring-cloud-sleuth/issues/646","id":365868635,"user":{"login":"marcingrzejszczak","id":3297437,"avatar_url":"https://avatars0.githubusercontent.com/u/3297437?v=4","gravatar_id":"","url":"https://api.github.com/users/marcingrzejszczak","html_url":"https://github.com/marcingrzejszczak","followers_url":"https://api.github.com/users/marcingrzejszczak/followers","following_url":"https://api.github.com/users/marcingrzejszczak/following{/other_user}","gists_url":"https://api.github.com/users/marcingrzejszczak/gists{/gist_id}","starred_url":"https://api.github.com/users/marcingrzejszczak/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/marcingrzejszczak/subscriptions","organizations_url":"https://api.github.com/users/marcingrzejszczak/orgs","repos_url":"https://api.github.com/users/marcingrzejszczak/repos","events_url":"https://api.github.com/users/marcingrzejszczak/events{/privacy}","received_events_url":"https://api.github.com/users/marcingrzejszczak/received_events","type":"User","site_admin":false},"created_at":"2018-02-15T09:21:01Z","updated_at":"2018-02-15T09:21:01Z","author_association":"CONTRIBUTOR","body":"Can you setup a sample that we can use to replicate this problem?"}}
{"actor":{"display_login":"marcingrzejszczak"}}