|
Change Parameter Type eventStream : MessageStream<TrackedEventMessage<?>> to eventStream : BlockingStream<TrackedEventMessage<?>> in method private checkSegmentCaughtUp(segment Segment, eventStream BlockingStream<TrackedEventMessage<?>>) : void in class org.axonframework.eventhandling.TrackingEventProcessor |
From |
To |
|
Change Parameter Type delegate : MessageStream<TrackedEventMessage<?>> to delegate : BlockingStream<TrackedEventMessage<?>> in method public ReplayingMessageStream(token ReplayToken, delegate BlockingStream<TrackedEventMessage<?>>) in class org.axonframework.eventhandling.TrackingEventProcessor.ReplayingMessageStream |
From |
To |
|
Change Parameter Type eventStreamIn : MessageStream<TrackedEventMessage<?>> to eventStreamIn : BlockingStream<TrackedEventMessage<?>> in method private ensureEventStreamOpened(eventStreamIn BlockingStream<TrackedEventMessage<?>>, segment Segment) : BlockingStream<TrackedEventMessage<?>> in class org.axonframework.eventhandling.TrackingEventProcessor |
From |
To |
|
Change Parameter Type eventStream : MessageStream<TrackedEventMessage<?>> to eventStream : BlockingStream<TrackedEventMessage<?>> in method private processBatch(segment Segment, eventStream BlockingStream<TrackedEventMessage<?>>) : void in class org.axonframework.eventhandling.TrackingEventProcessor |
From |
To |
|
Change Parameter Type messageStream : MessageStream<M> to messageStream : BlockingStream<M> in method public asStream(messageStream BlockingStream<M>) : Stream<M> in class org.axonframework.common.stream.StreamUtils |
From |
To |
|
Change Return Type MessageStream<TrackedEventMessage<?>> to BlockingStream<TrackedEventMessage<?>> in method private doOpenStream(trackingToken TrackingToken) : BlockingStream<TrackedEventMessage<?>> in class org.axonframework.eventhandling.TrackingEventProcessor |
From |
To |
|
Change Return Type MessageStream<TrackedEventMessage<?>> to BlockingStream<TrackedEventMessage<?>> in method public start(token KafkaTrackingToken) : BlockingStream<TrackedEventMessage<?>> in class org.axonframework.kafka.eventhandling.consumer.Fetcher |
From |
To |
|
Change Return Type MessageStream<M> to BlockingStream<M> in method public openStream(trackingToken TrackingToken) : BlockingStream<M> in class org.axonframework.messaging.StreamableMessageSource |
From |
To |
|
Change Return Type MessageStream<TrackedEventMessage<?>> to BlockingStream<TrackedEventMessage<?>> in method public openStream(trackingToken TrackingToken) : BlockingStream<TrackedEventMessage<?>> in class org.axonframework.kafka.eventhandling.consumer.KafkaMessageSource |
From |
To |
|
Change Return Type MessageStream<TrackedEventMessage<?>> to BlockingStream<TrackedEventMessage<?>> in method public start(token KafkaTrackingToken) : BlockingStream<TrackedEventMessage<?>> in class org.axonframework.kafka.eventhandling.consumer.AsyncFetcher |
From |
To |
|
Change Return Type MessageStream<TrackedEventMessage<?>> to BlockingStream<TrackedEventMessage<?>> in method private ensureEventStreamOpened(eventStreamIn BlockingStream<TrackedEventMessage<?>>, segment Segment) : BlockingStream<TrackedEventMessage<?>> in class org.axonframework.eventhandling.TrackingEventProcessor |
From |
To |