File tree Expand file tree Collapse file tree 2 files changed +9
-2
lines changed
src/main/java/com/ibm/eventstreams/connect/mqsource/processor Expand file tree Collapse file tree 2 files changed +9
-2
lines changed Original file line number Diff line number Diff line change 94
94
<configuration >
95
95
<source >1.8</source >
96
96
<target >1.8</target >
97
+ <compilerArgument >-Xlint:unchecked</compilerArgument >
97
98
</configuration >
98
99
</plugin >
99
100
<plugin >
Original file line number Diff line number Diff line change 23
23
import javax .jms .Message ;
24
24
import java .util .ArrayList ;
25
25
import java .util .Collections ;
26
+ import java .util .Enumeration ;
27
+ import java .util .List ;
26
28
27
29
/*
28
30
* Single responsibility class to copy JMS properties to Kafka headers.
@@ -44,9 +46,13 @@ public ConnectHeaders convertJmsPropertiesToKafkaHeaders(Message message) {
44
46
45
47
ConnectHeaders connectHeaders = new ConnectHeaders ();
46
48
47
- ArrayList jmsPropertyKeys = null ;
49
+
48
50
try {
49
- jmsPropertyKeys = Collections .list (message .getPropertyNames ());
51
+ @ SuppressWarnings ("unchecked" )
52
+ //com.ibm.msg.client.jms.internal.JmsMessageImpl.getPropertyNames returns Enumeration<String>
53
+ Enumeration <String > propertyNames = (Enumeration <String >)message .getPropertyNames ();
54
+ List <String > jmsPropertyKeys = Collections .list (propertyNames );
55
+
50
56
jmsPropertyKeys .forEach (key -> {
51
57
try {
52
58
connectHeaders .addString (key .toString (), message .getObjectProperty (key .toString ()).toString ());
You can’t perform that action at this time.
0 commit comments