|
Change Parameter Type subscriber : Subscriber<? super StreamPayload<Exchange>> to subscriber : Subscriber<? super Exchange> in method public subscribe(subscriber Subscriber<? super Exchange>) : void in class org.apache.camel.component.reactive.streams.engine.CamelPublisher |
From |
To |
|
Change Parameter Type subscriber : Subscriber<? super StreamPayload<Exchange>> to subscriber : Subscriber<? super Exchange> in method public CamelSubscription(workerPool ExecutorService, publisher CamelPublisher, name String, backpressureStrategy ReactiveStreamsBackpressureStrategy, subscriber Subscriber<? super Exchange>) in class org.apache.camel.component.reactive.streams.engine.CamelSubscription |
From |
To |
|
Change Parameter Type data : StreamPayload<Exchange> to data : Exchange in method public publish(data Exchange) : void in class org.apache.camel.component.reactive.streams.engine.CamelPublisher |
From |
To |
|
Change Parameter Type delegate : Publisher<StreamPayload<R>> to delegate : Publisher<Exchange> in method public UnwrappingPublisher(delegate Publisher<Exchange>) in class org.apache.camel.component.reactive.streams.engine.UnwrappingPublisher |
From |
To |
|
Change Parameter Type subscriber : Subscriber<? super R> to subscriber : Subscriber<? super Exchange> in method public subscribe(subscriber Subscriber<? super Exchange>) : void in class org.apache.camel.component.reactive.streams.engine.UnwrappingPublisher |
From |
To |
|
Change Parameter Type message : StreamPayload<Exchange> to message : Exchange in method public publish(message Exchange) : void in class org.apache.camel.component.reactive.streams.engine.CamelSubscription |
From |
To |
|
Change Parameter Type remaining : List<StreamPayload<Exchange>> to remaining : List<Exchange> in method protected discardBuffer(remaining List<Exchange>) : void in class org.apache.camel.component.reactive.streams.engine.CamelSubscription |
From |
To |
|
Change Variable Type discarded : Collection<StreamPayload<Exchange>> to discarded : Collection<Exchange> in method public publish(message Exchange) : void in class org.apache.camel.component.reactive.streams.engine.CamelSubscription |
From |
To |
|
Change Variable Type data : StreamPayload<Exchange> to data : Exchange in method protected discardBuffer(remaining List<Exchange>) : void in class org.apache.camel.component.reactive.streams.engine.CamelSubscription |
From |
To |
|
Change Variable Type bufferCopy : List<StreamPayload<Exchange>> to bufferCopy : List<Exchange> in method public cancel() : void in class org.apache.camel.component.reactive.streams.engine.CamelSubscription |
From |
To |
|
Change Variable Type discardedMessages : Map<StreamPayload<Exchange>,String> to discardedMessages : Map<Exchange,String> in method public publish(message Exchange) : void in class org.apache.camel.component.reactive.streams.engine.CamelSubscription |
From |
To |
|
Change Variable Type discarded : Map.Entry<StreamPayload<Exchange>,String> to discarded : Map.Entry<Exchange,String> in method public publish(message Exchange) : void in class org.apache.camel.component.reactive.streams.engine.CamelSubscription |
From |
To |
|
Change Variable Type ex : StreamPayload<Exchange> to ex : Exchange in method public publish(message Exchange) : void in class org.apache.camel.component.reactive.streams.engine.CamelSubscription |
From |
To |
|
Change Variable Type sendingQueue : LinkedList<StreamPayload<Exchange>> to sendingQueue : LinkedList<Exchange> in method protected flush() : void in class org.apache.camel.component.reactive.streams.engine.CamelSubscription |
From |
To |
|
Change Variable Type data : StreamPayload<Exchange> to data : Exchange in method protected flush() : void in class org.apache.camel.component.reactive.streams.engine.CamelSubscription |
From |
To |
|
Change Attribute Type subscriber : Subscriber<? super StreamPayload<Exchange>> to subscriber : Subscriber<? super Exchange> in class org.apache.camel.component.reactive.streams.engine.CamelSubscription |
From |
To |
|
Change Attribute Type buffer : LinkedList<StreamPayload<Exchange>> to buffer : LinkedList<Exchange> in class org.apache.camel.component.reactive.streams.engine.CamelSubscription |
From |
To |
|
Change Attribute Type delegate : Publisher<StreamPayload<R>> to delegate : Publisher<Exchange> in class org.apache.camel.component.reactive.streams.engine.UnwrappingPublisher |
From |
To |
|
Change Attribute Type subscribers : Map<String,CamelSubscriber> to subscribers : ConcurrentMap<String,CamelSubscriber> in class org.apache.camel.component.reactive.streams.engine.DefaultCamelReactiveStreamsService |
From |
To |
|
Change Attribute Type publishedUriToStream : Map<String,String> to publishedUriToStream : ConcurrentMap<String,String> in class org.apache.camel.component.reactive.streams.engine.DefaultCamelReactiveStreamsService |
From |
To |
|
Change Attribute Type publishers : Map<String,CamelPublisher> to publishers : ConcurrentMap<String,CamelPublisher> in class org.apache.camel.component.reactive.streams.engine.DefaultCamelReactiveStreamsService |
From |
To |
|
Change Attribute Type requestedUriToStream : Map<String,String> to requestedUriToStream : ConcurrentMap<String,String> in class org.apache.camel.component.reactive.streams.engine.DefaultCamelReactiveStreamsService |
From |
To |