a161606a6e9c7191a8afd8a003c8a46be2350f76
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type returnListener : ReturnListener to returnListener : SerializableReturnListener in method private RMQSink(rmqConnectionConfig RMQConnectionConfig, queueName String, schema SerializationSchema<IN>, publishOptions RMQSinkPublishOptions<IN>, returnListener SerializableReturnListener) in class org.apache.flink.streaming.connectors.rabbitmq.RMQSink | From | To | |
| Change Parameter Type returnListener : ReturnListener to returnListener : SerializableReturnListener in method public RMQSink(rmqConnectionConfig RMQConnectionConfig, schema SerializationSchema<IN>, publishOptions RMQSinkPublishOptions<IN>, returnListener SerializableReturnListener) in class org.apache.flink.streaming.connectors.rabbitmq.RMQSink | From | To | |
| Extract Interface | 1 | ||
| Extract Interface org.apache.flink.streaming.connectors.rabbitmq.SerializableReturnListener from classes [org.apache.flink.streaming.connectors.rabbitmq.RMQSinkTest.DummyReturnHandler] | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type returnListener : ReturnListener to returnListener : SerializableReturnListener in class org.apache.flink.streaming.connectors.rabbitmq.RMQSink | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter arg0 : int to replyCode : int in method public handleReturn(replyCode int, replyText String, exchange String, routingKey String, properties BasicProperties, body byte[]) : void in class org.apache.flink.streaming.connectors.rabbitmq.RMQSinkTest.DummyReturnHandler | From | To | |
| Rename Parameter arg5 : byte[] to body : byte[] in method public handleReturn(replyCode int, replyText String, exchange String, routingKey String, properties BasicProperties, body byte[]) : void in class org.apache.flink.streaming.connectors.rabbitmq.RMQSinkTest.DummyReturnHandler | From | To | |
| Rename Parameter arg4 : BasicProperties to properties : BasicProperties in method public handleReturn(replyCode int, replyText String, exchange String, routingKey String, properties BasicProperties, body byte[]) : void in class org.apache.flink.streaming.connectors.rabbitmq.RMQSinkTest.DummyReturnHandler | From | To |