[GitHub] activemq-artemis issue #1793: ARTEMIS-1498: Openwire internal headers should...

[michaelandrepearce]

Github user michaelandrepearce commented on the issue:

    https://github.com/apache/activemq-artemis/pull/1793
  
    Copied from example i gave originally: 
https://github.com/apache/activemq-artemis/pull/1793
    
    e.g. along this line.
    
    public class OpenwireMessage extends RefCountMessage {
    
       org.apache.activemq.command.Message message;
       
       public OpenwireMessage(org.apache.activemq.command.Message message){
          this.message = message;
       }
    
       @Override
       public SimpleString getReplyTo() {
          return 
SimpleString.toSimpleString(message.getReplyTo().getPhysicalName());
       }
    
       @Override
       public Message setReplyTo(SimpleString address) {
          
message.setReplyTo(ActiveMQDestination.createDestination(address.toString(), 
ActiveMQDestination.QUEUE_TYPE));
          return this;
       }
    
       @Override
       public Object getUserID() {
          return message.getUserID();
       }
    
       @Override
       public Message setUserID(Object userID) {
          message.setUserID(userID.toString());
          return this;
       }
    
       @Override
       public boolean isDurable() {
          return message.isPersistent();
       }
    
       @Override
       public Message setDurable(boolean durable) {
          message.setPersistent(durable);
          return this;
       }
       .....
    }


---