File tree Expand file tree Collapse file tree 3 files changed +6
-6
lines changed
java/com/hivemq/extensions/kafka/customizations/helloworld
test/java/com/hivemq/extensions/kafka/customizations/helloworld Expand file tree Collapse file tree 3 files changed +6
-6
lines changed Original file line number Diff line number Diff line change 51
51
*
52
52
* @author Georg Held
53
53
*/
54
- public class HelloWorldTransformer implements MqttToKafkaTransformer {
54
+ public class MqttToKafkaHelloWorldTransformer implements MqttToKafkaTransformer {
55
55
56
- private static final @ NotNull Logger log = LoggerFactory .getLogger (HelloWorldTransformer .class );
56
+ private static final @ NotNull Logger log = LoggerFactory .getLogger (MqttToKafkaHelloWorldTransformer .class );
57
57
58
58
@ Override
59
59
public void init (final @ NotNull MqttToKafkaInitInput input ) {
Original file line number Diff line number Diff line change 33
33
<mqtt-topic-filters >
34
34
<mqtt-topic-filter >transform/#</mqtt-topic-filter >
35
35
</mqtt-topic-filters >
36
- <transformer >com.hivemq.extensions.kafka.customizations.helloworld.HelloWorldTransformer </transformer >
36
+ <transformer >com.hivemq.extensions.kafka.customizations.helloworld.MqttToKafkaHelloWorldTransformer </transformer >
37
37
</mqtt-to-kafka-transformer >
38
38
</mqtt-to-kafka-transformers >
39
39
Original file line number Diff line number Diff line change 36
36
import static org .mockito .ArgumentMatchers .anyString ;
37
37
import static org .mockito .Mockito .*;
38
38
39
- class HelloWorldTransformerTest {
39
+ class MqttToKafkaHelloWorldTransformerTest {
40
40
41
41
// mock objects
42
42
private MqttToKafkaInput input ;
@@ -48,7 +48,7 @@ class HelloWorldTransformerTest {
48
48
private UserProperty userProperty ;
49
49
50
50
// test object
51
- private HelloWorldTransformer transformer ;
51
+ private MqttToKafkaHelloWorldTransformer transformer ;
52
52
53
53
@ BeforeEach
54
54
void setUp () {
@@ -84,7 +84,7 @@ void setUp() {
84
84
when (userProperty .getValue ()).thenReturn ("test-value" );
85
85
when (publishPacket .getUserProperties ()).thenReturn (userProperties );
86
86
87
- transformer = new HelloWorldTransformer ();
87
+ transformer = new MqttToKafkaHelloWorldTransformer ();
88
88
}
89
89
90
90
@ SuppressWarnings ("OptionalGetWithoutIsPresent" )
You can’t perform that action at this time.
0 commit comments