Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

This closes #689

This commit is contained in:
Clebert Suconic 2016-07-29 15:44:40 -04:00
parent 9073e4cd74 a1fd6f56ba
commit f44e87f43e
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
integration/activemq-aerogear-integration/src/main/java/org/apache/activemq/artemis/integration/aerogear/AeroGearConnectorService.java
View File

@ -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());
}
}