|
Change Parameter Type buffer : BlockingQueue<MessageAndTimestamp> to buffer : MessageBuffer<MessageAndMetadata> in method public KafkaMessageStream(buffer MessageBuffer<MessageAndMetadata>, fetcher Fetcher) in class org.axonframework.kafka.eventhandling.consumer.KafkaMessageStream |
From |
To |
|
Change Parameter Type channel : BlockingQueue<MessageAndTimestamp> to channel : MessageBuffer<MessageAndMetadata> in method package FetchEventsTask(consumer Consumer<K,V>, token KafkaTrackingToken, channel MessageBuffer<MessageAndMetadata>, converter KafkaMessageConverter<K,V>) in class org.axonframework.kafka.eventhandling.consumer.FetchEventsTask |
From |
To |
|
Change Parameter Type buffer : BlockingQueue<MessageAndTimestamp> to buffer : MessageBuffer<MessageAndMetadata> in method package BufferedEventStream(buffer MessageBuffer<MessageAndMetadata>) in class org.axonframework.kafka.eventhandling.consumer.BufferedEventStream |
From |
To |
|
Change Parameter Type fetcher : Fetcher<K,V> to fetcher : Fetcher in method public KafkaMessageStream(buffer MessageBuffer<MessageAndMetadata>, fetcher Fetcher) in class org.axonframework.kafka.eventhandling.consumer.KafkaMessageStream |
From |
To |
|
Change Return Type BufferedEventStream<String,byte[]> to BufferedEventStream in method private stream(messages List<GenericTrackedDomainEventMessage<String>>) : BufferedEventStream in class org.axonframework.kafka.eventhandling.consumer.BufferedEventStreamTests |
From |
To |
|
Change Return Type KafkaMessageStream<String,byte[]> to KafkaMessageStream in method private stream(messages List<GenericTrackedDomainEventMessage<String>>) : KafkaMessageStream in class org.axonframework.kafka.eventhandling.consumer.KafkaMessageStreamTests |
From |
To |
|
Change Return Type KafkaMessageStream<String,byte[]> to KafkaMessageStream in method private emptyStream() : KafkaMessageStream in class org.axonframework.kafka.eventhandling.consumer.KafkaMessageStreamTests |
From |
To |
|
Change Return Type BufferedEventStream<String,byte[]> to BufferedEventStream in method private emptyStream() : BufferedEventStream in class org.axonframework.kafka.eventhandling.consumer.BufferedEventStreamTests |
From |
To |
|
Change Variable Type testSubject : BufferedEventStream<String,byte[]> to testSubject : BufferedEventStream in method public testHasNextAvailableOnAProgressiveStream() : void in class org.axonframework.kafka.eventhandling.consumer.BufferedEventStreamTests |
From |
To |
|
Change Variable Type testSubject : BufferedEventStream<String,byte[]> to testSubject : BufferedEventStream in method public testPeekOnAnInterruptedStream() : void in class org.axonframework.kafka.eventhandling.consumer.BufferedEventStreamTests |
From |
To |
|
Change Variable Type testSubject : BufferedEventStream<String,byte[]> to testSubject : BufferedEventStream in method public testPeekOnNonEmptyStream() : void in class org.axonframework.kafka.eventhandling.consumer.BufferedEventStreamTests |
From |
To |
|
Change Variable Type testSubject : KafkaMessageStream<String,byte[]> to testSubject : KafkaMessageStream in method public testHasNextAvailableOnNonEmptyStream() : void in class org.axonframework.kafka.eventhandling.consumer.KafkaMessageStreamTests |
From |
To |
|
Change Variable Type testSubject : BufferedEventStream<String,byte[]> to testSubject : BufferedEventStream in method public testHasNextOnAnInterruptedStream() : void in class org.axonframework.kafka.eventhandling.consumer.BufferedEventStreamTests |
From |
To |
|
Change Variable Type testSubject : KafkaMessageStream<String,byte[]> to testSubject : KafkaMessageStream in method public testPeekOnNonEmptyStream() : void in class org.axonframework.kafka.eventhandling.consumer.KafkaMessageStreamTests |
From |
To |
|
Change Variable Type testSubject : KafkaMessageStream<String,byte[]> to testSubject : KafkaMessageStream in method public testHasNextOnAnInterruptedStream() : void in class org.axonframework.kafka.eventhandling.consumer.KafkaMessageStreamTests |
From |
To |
|
Change Variable Type testSubject : KafkaMessageStream<String,byte[]> to testSubject : KafkaMessageStream in method public testNextAvailableOnAProgressiveStream() : void in class org.axonframework.kafka.eventhandling.consumer.KafkaMessageStreamTests |
From |
To |
|
Change Variable Type testSubject : BufferedEventStream<String,byte[]> to testSubject : BufferedEventStream in method public testNextAvailableOnAProgressiveStream() : void in class org.axonframework.kafka.eventhandling.consumer.BufferedEventStreamTests |
From |
To |
|
Change Variable Type testSubject : KafkaMessageStream<String,byte[]> to testSubject : KafkaMessageStream in method public testNextAvailableOnAnInterruptedStream() : void in class org.axonframework.kafka.eventhandling.consumer.KafkaMessageStreamTests |
From |
To |
|
Change Variable Type testSubject : BufferedEventStream<String,byte[]> to testSubject : BufferedEventStream in method public testHasNextAvailableOnNonEmptyStream() : void in class org.axonframework.kafka.eventhandling.consumer.BufferedEventStreamTests |
From |
To |
|
Change Variable Type buffer : PriorityBlockingQueue<MessageAndTimestamp> to buffer : MessageBuffer<MessageAndMetadata> in method private stream(messages List<GenericTrackedDomainEventMessage<String>>) : BufferedEventStream in class org.axonframework.kafka.eventhandling.consumer.BufferedEventStreamTests |
From |
To |
|
Change Variable Type testSubject : KafkaMessageStream<String,byte[]> to testSubject : KafkaMessageStream in method public testPeekOnAProgressiveStream() : void in class org.axonframework.kafka.eventhandling.consumer.KafkaMessageStreamTests |
From |
To |
|
Change Variable Type buffer : PriorityBlockingQueue<MessageAndTimestamp> to buffer : MessageBuffer<MessageAndMetadata> in method public test() : void in class org.axonframework.kafka.eventhandling.consumer.FetchEventsTaskTests |
From |
To |
|
Change Variable Type testSubject : BufferedEventStream<String,byte[]> to testSubject : BufferedEventStream in method public testPeekOnAProgressiveStream() : void in class org.axonframework.kafka.eventhandling.consumer.BufferedEventStreamTests |
From |
To |
|
Change Variable Type testSubject : KafkaMessageStream<String,byte[]> to testSubject : KafkaMessageStream in method public testHasNextAvailableOnAProgressiveStream() : void in class org.axonframework.kafka.eventhandling.consumer.KafkaMessageStreamTests |
From |
To |
|
Change Variable Type buffer : PriorityBlockingQueue<MessageAndTimestamp> to buffer : MessageBuffer<MessageAndMetadata> in method private stream(messages List<GenericTrackedDomainEventMessage<String>>) : KafkaMessageStream in class org.axonframework.kafka.eventhandling.consumer.KafkaMessageStreamTests |
From |
To |
|
Change Variable Type testSubject : KafkaMessageStream<String,byte[]> to testSubject : KafkaMessageStream in method public testPeekOnAnInterruptedStream() : void in class org.axonframework.kafka.eventhandling.consumer.KafkaMessageStreamTests |
From |
To |
|
Change Variable Type testSubject : BufferedEventStream<String,byte[]> to testSubject : BufferedEventStream in method public testNextAvailableOnAnInterruptedStream() : void in class org.axonframework.kafka.eventhandling.consumer.BufferedEventStreamTests |
From |
To |