RoutedMessage.java |
/* * JBossMQ, the OpenSource JMS implementation * * Distributable under LGPL license. * See terms of license at gnu.org. */ package org.jboss.mq.server; import org.jboss.mq.ReceiveRequest; /** * This class contians all the data needed to perform a JMS transaction * * @author Hiram Chirino (Cojonudo14@hotmail.com) * @version $Revision: 1.5 $ */ public class RoutedMessage { // The message public MessageReference message; public Integer subscriptionId; ReceiveRequest toReceiveRequest() throws javax.jms.JMSException { ReceiveRequest rr = new ReceiveRequest(); rr.message = message.getMessageForDelivery(); rr.subscriptionId = subscriptionId; return rr; } }
RoutedMessage.java |