1 22 package org.jboss.mq.server; 23 24 import org.jboss.mq.ReceiveRequest; 25 26 32 public class RoutedMessage 33 { 34 public MessageReference message; 36 public Integer subscriptionId; 37 38 ReceiveRequest toReceiveRequest() throws javax.jms.JMSException  39 { 40 ReceiveRequest rr = new ReceiveRequest(); 41 rr.message = message.getMessageForDelivery(); 42 rr.subscriptionId = subscriptionId; 43 return rr; 44 } 45 } 46 | Popular Tags |