0dff50f43b0a3360f38ed84fdbab935270705f2d
Files Diff
- Added: 2
- Removed: 1
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 2 | ||
| Rename Method public testSendMessage_WithUnitOfWorkRollback() : void renamed to public testSendMessage_UnitOfWorkRollback() : void in class org.axonframework.kafka.eventhandling.producer.KafkaPublisherTests | From | To | |
| Rename Method private publishEventsToKafka(events List<? extends EventMessage<?>>, producer Producer<K,V>) : Map<Future<RecordMetadata>,? super EventMessage<?>> renamed to private publishToKafka(events List<? extends EventMessage<?>>, producer Producer<K,V>) : Map<Future<RecordMetadata>,? super EventMessage<?>> in class org.axonframework.kafka.eventhandling.producer.KafkaPublisher | From | To | |
| Move And Rename Method | 1 | ||
| Move And Rename Method private receiverConfigs(brokers String, group String, autoCommit String) : Map<String,Object> from class org.axonframework.kafka.eventhandling.producer.KafkaPublisherTests to public minimal(kafka KafkaEmbedded, groupName String, valueDeserializer Class) : Map<String,Object> from class org.axonframework.kafka.eventhandling.ConsumerConfigUtil | From | To | |
| Change Parameter Type | 1 | ||
| Change Parameter Type headers : org.apache.kafka.common.header.Headers to headers : Headers in method private domainEvent(headers Headers, message SerializedMessage<?>, timestamp long) : Optional<EventMessage<?>> in class org.axonframework.kafka.eventhandling.DefaultKafkaMessageConverter | From | To | |
| Inline Method | 3 | ||
| Inline Method private ingestMessages(events List<? extends EventMessage<?>>) : Map<? super EventMessage<?>,MonitorCallback> inlined to protected send(events List<? extends EventMessage<?>>) : void in class org.axonframework.kafka.eventhandling.producer.KafkaPublisher | From | To | |
| Inline Method private senderMessage(eventMessage EventMessage<?>) : ProducerRecord<String,byte[]> inlined to public testWriteAndRead_DomainEventMessage() : void in class org.axonframework.kafka.eventhandling.DefaultKafkaMessageConverterTests | From | To | |
| Inline Method private senderMessage(eventMessage EventMessage<?>) : ProducerRecord<String,byte[]> inlined to public testWriteAndRead_EventMessage() : void in class org.axonframework.kafka.eventhandling.DefaultKafkaMessageConverterTests | From | To | |
| Rename Variable | 7 | ||
| Rename Variable actualResult : EventMessage<?> to actual : EventMessage<?> in method public testWriteAndRead_EventMessage() : void in class org.axonframework.kafka.eventhandling.DefaultKafkaMessageConverterTests | From | To | |
| Rename Variable confirmationMode : ConfirmationMode to cm : ConfirmationMode in method protected send(events List<? extends EventMessage<?>>) : void in class org.axonframework.kafka.eventhandling.producer.KafkaPublisher | From | To | |
| Rename Variable unitOfWork : UnitOfWork<?> to uow : UnitOfWork<?> in method private handleActiveUnitOfWork(producer Producer<K,V>, futures Map<Future<RecordMetadata>,? super EventMessage<?>>, monitorCallbacks Map<? super EventMessage<?>,MonitorCallback>, confirmationMode ConfirmationMode) : void in class org.axonframework.kafka.eventhandling.producer.KafkaPublisher | From | To | |
| Rename Variable actualResult : EventMessage<?> to actual : EventMessage<?> in method public testWriteAndRead_DomainEventMessage() : void in class org.axonframework.kafka.eventhandling.DefaultKafkaMessageConverterTests | From | To | |
| Rename Variable eventMessage : EventMessage<?> to expected : EventMessage<?> in method public testWriteAndRead_EventMessage() : void in class org.axonframework.kafka.eventhandling.DefaultKafkaMessageConverterTests | From | To | |
| Rename Variable serializedMessage : SimpleSerializedObject<byte[]> to serializedObject : SimpleSerializedObject<byte[]> in method private extractSerializedMessage(headers Headers, messageBody byte[]) : SerializedMessage<?> in class org.axonframework.kafka.eventhandling.DefaultKafkaMessageConverter | From | To | |
| Rename Variable domainMessage : DomainEventMessage<?> to expected : DomainEventMessage<?> in method public testWriteAndRead_DomainEventMessage() : void in class org.axonframework.kafka.eventhandling.DefaultKafkaMessageConverterTests | From | To | |
| Change Return Type | 1 | ||
| Change Return Type Optional<EventMessage<?>> to EventMessage<?> in method private receiverMessage(senderMessage ProducerRecord<String,byte[]>) : EventMessage<?> in class org.axonframework.kafka.eventhandling.DefaultKafkaMessageConverterTests | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute producerFactory : DefaultProducerFactory<String,byte[]> to ackProducerFactory : ProducerFactory<String,byte[]> in class org.axonframework.kafka.eventhandling.producer.KafkaPublisherTests | From | To | |
| Rename Attribute testSubject : KafkaPublisher<String,byte[]> to txnProducerFactory : ProducerFactory<String,byte[]> in class org.axonframework.kafka.eventhandling.producer.KafkaPublisherTests | From | To | |
| Change Variable Type | 3 | ||
| Change Variable Type consumer : Consumer<String,byte[]> to consumer : Consumer<?,?> in method private consumer(topic String) : Consumer<?,?> in class org.axonframework.kafka.eventhandling.producer.KafkaPublisherTests | From | To | |
| Change Variable Type headers : org.apache.kafka.common.header.Headers to headers : Headers in method public readKafkaMessage(consumerRecord ConsumerRecord<String,byte[]>) : Optional<EventMessage<?>> in class org.axonframework.kafka.eventhandling.DefaultKafkaMessageConverter | From | To | |
| Change Attribute Type | 2 | ||
| Change Attribute Type testSubject : KafkaPublisher<String,byte[]> to txnProducerFactory : ProducerFactory<String,byte[]> in class org.axonframework.kafka.eventhandling.producer.KafkaPublisherTests | From | To | |
| Change Attribute Type producerFactory : DefaultProducerFactory<String,byte[]> to ackProducerFactory : ProducerFactory<String,byte[]> in class org.axonframework.kafka.eventhandling.producer.KafkaPublisherTests | From | To | |
| Extract Method | 3 | ||
| Extract Method private extractSerializedMessage(headers Headers, messageBody byte[]) : SerializedMessage<?> extracted from public readKafkaMessage(consumerRecord ConsumerRecord<String,byte[]>) : Optional<EventMessage<?>> in class org.axonframework.kafka.eventhandling.DefaultKafkaMessageConverter | From | To | |
| Extract Method private consumer(topic String) : Consumer<?,?> extracted from public testSendMessage_NoUnitOfWork() : void in class org.axonframework.kafka.eventhandling.producer.KafkaPublisherTests | From | To | |
| Extract Method private consumer(topic String) : Consumer<?,?> extracted from public testSendMessage_WithUnitOfWorkRollback() : void in class org.axonframework.kafka.eventhandling.producer.KafkaPublisherTests | From | To | |
| Rename Parameter | 2 | ||
| Rename Parameter monitorCallbackMap : Map<? super EventMessage<?>,MonitorCallback> to monitorCallbacks : Map<? super EventMessage<?>,MonitorCallback> in method private waitForPublishAck(futures Map<Future<RecordMetadata>,? super EventMessage<?>>, monitorCallbacks Map<? super EventMessage<?>,MonitorCallback>) : void in class org.axonframework.kafka.eventhandling.producer.KafkaPublisher | From | To | |
| Rename Parameter monitorCallbackMap : Map<? super EventMessage<?>,MonitorCallback> to monitorCallbacks : Map<? super EventMessage<?>,MonitorCallback> in method private handleActiveUnitOfWork(producer Producer<K,V>, futures Map<Future<RecordMetadata>,? super EventMessage<?>>, monitorCallbacks Map<? super EventMessage<?>,MonitorCallback>, confirmationMode ConfirmationMode) : void in class org.axonframework.kafka.eventhandling.producer.KafkaPublisher | From | To |