git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

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


Github user michaelandrepearce commented on the issue:

    https://github.com/apache/activemq-artemis/pull/1684
  
    e.g. 
    
    ```
    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;
       }
       .....
    }
    ```


---