|
Change Parameter Type buffer : SortableBuffer<MessageAndMetadata> to buffer : Buffer<KafkaEventMessage> in method public builder(consumer Consumer<K,V>, token KafkaTrackingToken, buffer Buffer<KafkaEventMessage>, converter KafkaMessageConverter<K,V>, callback BiFunction<ConsumerRecord<K,V>,KafkaTrackingToken,Void>, timeout long) : Builder<K,V> in class org.axonframework.kafka.eventhandling.consumer.FetchEventsTask |
From |
To |
|
Change Parameter Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method private assertMessagesCountPerPartition(expectedMessages int, p0 int, p1 int, p2 int, p3 int, p4 int, buffer SortedKafkaMessageBuffer<KafkaEventMessage>) : void in class org.axonframework.kafka.eventhandling.consumer.AsyncFetcherTests |
From |
To |
|
Change Parameter Type messages : List<? extends T> to messages : Collection<? extends T> in method public onMessagesIngested(messages Collection<? extends T>) : Map<? super T,MonitorCallback> in class org.axonframework.monitoring.MessageMonitor |
From |
To |
|
Change Parameter Type fetcher : Fetcher to closeHandler : Runnable in method public KafkaMessageStream(buffer Buffer<KafkaEventMessage>, closeHandler Runnable) in class org.axonframework.kafka.eventhandling.consumer.KafkaMessageStream |
From |
To |
|
Change Parameter Type other : MessageAndMetadata to other : KafkaEventMessage in method public compareTo(other KafkaEventMessage) : int in class org.axonframework.kafka.eventhandling.consumer.KafkaEventMessage |
From |
To |
|
Change Parameter Type buffer : SortableBuffer<MessageAndMetadata> to buffer : Buffer<KafkaEventMessage> in method public Builder(consumer Consumer<K,V>, token KafkaTrackingToken, buffer Buffer<KafkaEventMessage>, converter KafkaMessageConverter<K,V>, callback BiFunction<ConsumerRecord<K,V>,KafkaTrackingToken,Void>, timeout long) in class org.axonframework.kafka.eventhandling.consumer.FetchEventsTask.Builder |
From |
To |
|
Change Parameter Type buffer : SortableBuffer<MessageAndMetadata> to buffer : Buffer<KafkaEventMessage> in method public KafkaMessageStream(buffer Buffer<KafkaEventMessage>, closeHandler Runnable) in class org.axonframework.kafka.eventhandling.consumer.KafkaMessageStream |
From |
To |
|
Change Return Type MessageAndMetadata to KafkaEventMessage in method public peek() : KafkaEventMessage in class org.axonframework.kafka.eventhandling.benchmark.MessageBufferBenchmarks_PutPeekPoll |
From |
To |
|
Change Return Type MessageAndMetadata to KafkaEventMessage in method public take() : KafkaEventMessage in class org.axonframework.kafka.eventhandling.benchmark.MessageBufferBenchmarks_PutPeekTake |
From |
To |
|
Change Return Type MessageAndMetadata to KafkaEventMessage in method private message(partition int, offset int, timestamp int, value String) : KafkaEventMessage in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Return Type MessageAndMetadata to KafkaEventMessage in method public from(eventMessage EventMessage<?>, record ConsumerRecord<?,?>, token KafkaTrackingToken) : KafkaEventMessage in class org.axonframework.kafka.eventhandling.consumer.KafkaEventMessage |
From |
To |
|
Change Return Type MessageAndMetadata to KafkaEventMessage in method private message(partition int, offset int, timestamp int) : KafkaEventMessage in class org.axonframework.kafka.eventhandling.benchmark.MessageBufferBenchmarks_PutPeekTake |
From |
To |
|
Change Return Type MessageAndMetadata to KafkaEventMessage in method public poll() : KafkaEventMessage in class org.axonframework.kafka.eventhandling.benchmark.MessageBufferBenchmarks_PutPeekPoll |
From |
To |
|
Change Return Type MessageAndMetadata to KafkaEventMessage in method public peek() : KafkaEventMessage in class org.axonframework.kafka.eventhandling.benchmark.MessageBufferBenchmarks_PutPeekTake |
From |
To |
|
Change Return Type MessageAndMetadata to KafkaEventMessage in method private message(partition int, offset int, timestamp int) : KafkaEventMessage in class org.axonframework.kafka.eventhandling.benchmark.MessageBufferBenchmarks_PutPeekPoll |
From |
To |
|
Change Return Type MessageBuffer<MessageAndMetadata> to SortedKafkaMessageBuffer<KafkaEventMessage> in method package populatedBuffer(size int, minCapacity int, maxCapacity int) : SortedKafkaMessageBuffer<KafkaEventMessage> in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buff : MessageBuffer<? extends Comparable> to buff : SortedKafkaMessageBuffer<? extends Comparable> in method public testIsEmpty() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type message : MessageAndMetadata to message : KafkaEventMessage in method public put(state ThreadState) : void in class org.axonframework.kafka.eventhandling.benchmark.MessageBufferBenchmarks_PutPeekPoll |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testPoll_OnAnInterruptedStream() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type messages : List<MessageAndMetadata> to messages : List<KafkaEventMessage> in method public testPeek_MessagesPublishedAtTheSameTime_AcrossDifferentPartitions() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buff : MessageBuffer<MessageAndMetadata> to buff : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testBlockingPut() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testConcurrentPeekAndPoll() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type message : MessageAndMetadata to message : KafkaEventMessage in method public testTake_OffsetOrdering() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type messages : List<MessageAndMetadata> to messages : List<KafkaEventMessage> in method public testPoll_OffsetOrdering() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method private stream(messages List<GenericTrackedDomainEventMessage<String>>) : KafkaMessageStream in class org.axonframework.kafka.eventhandling.consumer.KafkaMessageStreamTests |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testConcurrentPeekAndTake() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type message : MessageAndMetadata to message : KafkaEventMessage in method public put(state ThreadState) : void in class org.axonframework.kafka.eventhandling.benchmark.MessageBufferBenchmarks_PutPeekTake |
From |
To |
|
Change Variable Type ordered : List<MessageAndMetadata> to ordered : List<KafkaEventMessage> in method public testTake_OffsetOrdering() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testPeek_OnAnInterruptedStream() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testStartFetcherWith_NullToken_ShouldStartFromBeginning() : void in class org.axonframework.kafka.eventhandling.consumer.AsyncFetcherTests |
From |
To |
|
Change Variable Type m : MessageAndMetadata to m : KafkaEventMessage in method private assertMessagesCountPerPartition(expectedMessages int, p0 int, p1 int, p2 int, p3 int, p4 int, buffer SortedKafkaMessageBuffer<KafkaEventMessage>) : void in class org.axonframework.kafka.eventhandling.consumer.AsyncFetcherTests |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testPeekAndPoll_ProgressiveBuffer() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testTake_OnAnInterruptedStream() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buff : MessageBuffer<MessageAndMetadata> to buff : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testRemainingCapacity() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type messages : List<MessageAndMetadata> to messages : List<KafkaEventMessage> in method public testPutAndTake_MessagesPublishedAtSameTime_OnSamePartition() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type messages : Collection<MessageAndMetadata> to messages : Collection<KafkaEventMessage> in method public run() : void in class org.axonframework.kafka.eventhandling.consumer.FetchEventsTask |
From |
To |
|
Change Variable Type messages : List<MessageAndMetadata> to messages : List<KafkaEventMessage> in method public testPutAndTake_TimestampOrdering() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testPut_OnAnInterruptedStream() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testPutAndTake_MessagesPublishedAtSameTime_OnSamePartition() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testPoll_OffsetOrdering() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testPutAndPoll_MessagesPublishedAtSameTime_AcrossDifferentPartitions() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testPutAndTake_TimestampOrdering() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testPutAndTake_ProgressiveBuffer() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type messages : List<MessageAndMetadata> to messages : List<KafkaEventMessage> in method public testTake_OffsetOrdering() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type messages : List<MessageAndMetadata> to messages : List<KafkaEventMessage> in method public testPutAndPoll_TimestampOrdering() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type messages : List<MessageAndMetadata> to messages : List<KafkaEventMessage> in method public testPutAndPoll_MessagesPublishedAtSameTime_AcrossDifferentPartitions() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testTaskExecution_StartingThreadAndInterrupt_ShouldNotCauseAnyException() : void in class org.axonframework.kafka.eventhandling.consumer.FetchEventsTaskTests |
From |
To |
|
Change Variable Type buff : MessageBuffer<MessageAndMetadata> to buff : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testEmptyFull() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testPutAndPoll_TimestampOrdering() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type message : MessageAndMetadata to message : KafkaEventMessage in method public testPoll_OffsetOrdering() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testPutAndPoll_ProgressiveBuffer() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testPeek_MessagesPublishedAtTheSameTime_AcrossDifferentPartitions() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buff : MessageBuffer<MessageAndMetadata> to buff : SortedKafkaMessageBuffer<KafkaEventMessage> in method package populatedBuffer(size int, minCapacity int, maxCapacity int) : SortedKafkaMessageBuffer<KafkaEventMessage> in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testPutAndTake_MessagesPublishedAtSameTime_AcrossDifferentPartitions() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type ordered : List<MessageAndMetadata> to ordered : List<KafkaEventMessage> in method public testPoll_OffsetOrdering() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testStartFetcherWith_ExistingToken_ShouldStartAtSpecificPositions() : void in class org.axonframework.kafka.eventhandling.consumer.AsyncFetcherTests |
From |
To |
|
Change Variable Type messages : List<MessageAndMetadata> to messages : List<KafkaEventMessage> in method public testPutAndPoll_MessagesPublishedAtSameTime_OnSamePartition() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testPutAndPoll_MessagesPublishedAtSameTime_OnSamePartition() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type buffer : MessageBuffer<MessageAndMetadata> to buffer : SortedKafkaMessageBuffer<KafkaEventMessage> in method public testTake_OffsetOrdering() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type message : MessageAndMetadata to message : KafkaEventMessage in method public testPeek_MessagesPublishedAtTheSameTime_AcrossDifferentPartitions() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |
|
Change Variable Type messages : List<MessageAndMetadata> to messages : List<KafkaEventMessage> in method public testPutAndTake_MessagesPublishedAtSameTime_AcrossDifferentPartitions() : void in class org.axonframework.kafka.eventhandling.consumer.SortedKafkaMessageBufferTests |
From |
To |