Skip to content

Commit 5d646e6

Browse files
committed
fixed the flag to take the default value for copying jms properties
1 parent 6839b24 commit 5d646e6

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

src/main/java/com/ibm/eventstreams/connect/mqsource/builders/BaseRecordBuilder.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -35,9 +35,7 @@
3535
public abstract class BaseRecordBuilder implements RecordBuilder {
3636
private static final Logger log = LoggerFactory.getLogger(BaseRecordBuilder.class);
3737
protected KeyHeader keyheader = KeyHeader.NONE;
38-
39-
;
40-
private Boolean copyJmsPropertiesFlag = false;
38+
private Boolean copyJmsPropertiesFlag = MQSourceConnector.CONFIG_VALUE_MQ_JMS_PROPERTY_COPY_TO_KAFKA_HEADER_DEFAULT;
4139
private JmsToKafkaHeaderConverter jmsToKafkaHeaderConverter;
4240

4341
/**
@@ -73,7 +71,7 @@ public void configure(Map<String, String> props) {
7371

7472
String str = props.get(MQSourceConnector.CONFIG_NAME_MQ_JMS_PROPERTY_COPY_TO_KAFKA_HEADER);
7573
if (str != null && ("true".equalsIgnoreCase(str) || "false".equalsIgnoreCase(str))) {
76-
copyJmsPropertiesFlag = Boolean.valueOf(str);
74+
copyJmsPropertiesFlag = Boolean.parseBoolean(str);
7775
jmsToKafkaHeaderConverter = new JmsToKafkaHeaderConverter();
7876
}
7977

0 commit comments

Comments
 (0)