[ https://issues.apache.org/jira/browse/ARTEMIS-4657?focusedWorklogId=908033&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-908033 ]
ASF GitHub Bot logged work on ARTEMIS-4657: ------------------------------------------- Author: ASF GitHub Bot Created on: 04/Mar/24 10:47 Start Date: 04/Mar/24 10:47 Worklog Time Spent: 10m Work Description: gemmellr commented on code in PR #4833: URL: https://github.com/apache/activemq-artemis/pull/4833#discussion_r1510962500 ########## artemis-protocols/artemis-openwire-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/openwire/OpenWireMessageConverter.java: ########## @@ -590,9 +590,9 @@ private static ActiveMQMessage toAMQMessage(MessageReference reference, } amqMsg.setCommandId(commandId); - final SimpleString corrId = getObjectProperty(coreMessage, SimpleString.class, OpenWireConstants.JMS_CORRELATION_ID_PROPERTY); - if (corrId != null) { - amqMsg.setCorrelationId(corrId.toString()); + final Object correlationID = coreMessage.getCorrelationID(); + if (correlationID != null) { + amqMsg.setCorrelationId(correlationID.toString()); Review Comment: The old code looks like it would get null if the types didnt match, and so not actually add thing...this looks more like it will start adding the toString() of non-Strings. Perhaps it should still be type-checking to avoid that, given the other changes make it more likely for this to receive non-String values now? Issue Time Tracking ------------------- Worklog Id: (was: 908033) Time Spent: 1.5h (was: 1h 20m) > Support correlation ID compatibility between JMS clients > -------------------------------------------------------- > > Key: ARTEMIS-4657 > URL: https://issues.apache.org/jira/browse/ARTEMIS-4657 > Project: ActiveMQ Artemis > Issue Type: Improvement > Reporter: Justin Bertram > Assignee: Justin Bertram > Priority: Major > Time Spent: 1.5h > Remaining Estimate: 0h > > Currently there are some use-cases with both {{String}} and {{byte[]}} values > of JMS correlation ID that don't work between Core, OpenWire, and AMQP. We > should support as many as possible. -- This message was sent by Atlassian Jira (v8.20.10#820010)