diff --git a/pulsar-jms-filters/src/main/java/com/datastax/oss/pulsar/jms/selectors/JMSFilter.java b/pulsar-jms-filters/src/main/java/com/datastax/oss/pulsar/jms/selectors/JMSFilter.java index 607c2acd..c4945a60 100644 --- a/pulsar-jms-filters/src/main/java/com/datastax/oss/pulsar/jms/selectors/JMSFilter.java +++ b/pulsar-jms-filters/src/main/java/com/datastax/oss/pulsar/jms/selectors/JMSFilter.java @@ -736,7 +736,7 @@ static Object getProperty(Map cacheProperties, String name) { // we pre-compute the type in order to avoid to scan the list to fine the type String type = SYSTEM_PROPERTIES_TYPES.get(name); if (type == null) { - type = cacheProperties.get(propertyType(name)); + type = propertyType(name); } String value = cacheProperties.get(name); return getObjectProperty(value, type);