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

ARTEMIS-128 ClassCastException in openwire message conversion

This commit is contained in:
Howard Gao 2015-05-29 20:18:17 +08:00 committed by Clebert Suconic
parent 7261eaebc5
commit afe5b5cefe
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireMessageConverter.java
View File

@ -647,9 +647,10 @@ public class OpenWireMessageConverter implements MessageConverter
amqMsg.setDestination(dest);
}
String groupId = (String) coreMessage.getObjectProperty(AMQ_MSG_GROUP_ID);
if (groupId != null)
Object value = coreMessage.getObjectProperty(AMQ_MSG_GROUP_ID);
if (value != null)
{
String groupId = value.toString();
amqMsg.setGroupID(groupId);
}