Fix allowable property check on add in AeroGearConnectorService.handle
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/a1fd6f56 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/a1fd6f56 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/a1fd6f56 Branch: refs/heads/master Commit: a1fd6f56bad06aa14f8397070feae6521e290561 Parents: 9073e4c Author: Ville Skyttä <[email protected]> Authored: Fri Jul 29 19:37:05 2016 +0300 Committer: Clebert Suconic <[email protected]> Committed: Fri Jul 29 15:44:40 2016 -0400 ---------------------------------------------------------------------- .../artemis/integration/aerogear/AeroGearConnectorService.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/a1fd6f56/integration/activemq-aerogear-integration/src/main/java/org/apache/activemq/artemis/integration/aerogear/AeroGearConnectorService.java ---------------------------------------------------------------------- diff --git a/integration/activemq-aerogear-integration/src/main/java/org/apache/activemq/artemis/integration/aerogear/AeroGearConnectorService.java b/integration/activemq-aerogear-integration/src/main/java/org/apache/activemq/artemis/integration/aerogear/AeroGearConnectorService.java index 1fb3ca1..6da582c 100644 --- a/integration/activemq-aerogear-integration/src/main/java/org/apache/activemq/artemis/integration/aerogear/AeroGearConnectorService.java +++ b/integration/activemq-aerogear-integration/src/main/java/org/apache/activemq/artemis/integration/aerogear/AeroGearConnectorService.java @@ -258,9 +258,10 @@ public class AeroGearConnectorService implements ConnectorService, Consumer, Mes Set<SimpleString> propertyNames = message.getPropertyNames(); for (SimpleString propertyName : propertyNames) { - if (propertyName.toString().startsWith("AEROGEAR_") && !AeroGearConstants.ALLOWABLE_PROPERTIES.contains(propertyName)) { + String nameString = propertyName.toString(); + if (nameString.startsWith("AEROGEAR_") && !AeroGearConstants.ALLOWABLE_PROPERTIES.contains(nameString)) { Object property = message.getTypedProperties().getProperty(propertyName); - builder.attribute(propertyName.toString(), property.toString()); + builder.attribute(nameString, property.toString()); } }
