diff --git a/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java b/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java index c1ce5cb301..492985fb4c 100755 --- a/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java +++ b/activemq-core/src/main/java/org/apache/activemq/ActiveMQMessageConsumer.java @@ -223,7 +223,7 @@ public class ActiveMQMessageConsumer implements MessageAvailableConsumer, StatsC // Allows the options on the destination to configure the consumerInfo if (dest.getOptions() != null) { - Map options = IntrospectionSupport.extractProperties(dest.getOptions(), "producer."); + Map options = IntrospectionSupport.extractProperties(dest.getOptions(), "consumer."); IntrospectionSupport.setProperties(this.info, options); if (options.size() > 0) { String msg = "There are " + options.size()