Wie JMSMessageID von JMS-Antwort abzurufen

Question

Ich habe versucht, einen Weg zu finden, aber konnte nicht JMSMessageID abrufen, die als Antwort von JMS nach dem Senden einer Nachricht an eine Warteschlange kommt. Würde mir bitte jemand helfen? Vielen Dank. (diese Frage ist ähnlich wie Extract JMSMessageID on response from JMS Queue, aber ich konnte weder die gleiche Frage kommentieren noch erneut anfragen, also eine neue Frage nach dem Vorschlag erstellen)

Answer 1

Sie können eine Antwort-Transformer-Java-Klasse verwenden, um dies zu tun. Stellen Sie sicher, dass Sie zuvor einen objectToJms-Transformer verwenden.

import javax.jms.JMSException; 
import javax.jms.Message; 

import org.apache.commons.lang.StringUtils; 
import org.mule.api.MuleMessage; 
import org.mule.api.transformer.TransformerException; 
import org.mule.api.transport.PropertyScope; 
import org.mule.transformer.AbstractMessageTransformer; 

public class ExtractJmsMessageIdTransformer extends AbstractMessageTransformer { 

    @Override 
    public Object transformMessage(MuleMessage message, String outputEncoding) throws TransformerException { 

     if (message.getPayload() instanceof Message) { 
      Message jmsMessage = (Message) message.getPayload(); 
      String jmsMessageId = null; 
      try { 

       jmsMessageId = jmsMessage.getJMSMessageID(); 
       logger.info("Found JmsMessage as payload. jmsMessageId = " + jmsMessageId) 
      } catch (final JMSException e) { 
       throw new TransformerException(this, e); 
      } 
     } 

     return message; 
    } 

}

EDIT1 Per Kommentare

Sie nicht die ExtractJmsMessageIdTransformer Klasse auf Ihrer Antwort Transformatoren definieren. In Ihrem mule-config.xml fügen Sie folgendes

<custom-transformer class="mypack.ExtractJmsMessageIdTransformer" name="extractJmsMessageIdTransformer"/> 

<jms:object-to-jmsmessage-transformer name="objectToJms" /> 

dann JMS-Warteschlange definieren wie diese

<jms:outbound-endpoint exchange-pattern="request-response" disableTemporaryReplyToDestinations="true" queue="sample" connector-ref="JMS" 
          doc:name="JMS" transformer-refs="objectToJms" responseTransformer-refs="objectToJms extractJmsMessageIdTransformer"/> 
    <logger level="INFO" doc:name="Logger" message="#[message.outboundProperties]"/>