SpyQueueSession.java |
/* * JBossMQ, the OpenSource JMS implementation * * Distributable under LGPL license. See terms of license at gnu.org. */ package org.jboss.mq; import javax.jms.QueueSession; import javax.jms.XAQueueSession; /** * This class implements javax.jms.QueueSession and javax.jms.XAQueueSession * * @author Norbert Lataille (Norbert.Lataille@m4x.org) * @author Hiram Chirino (Cojonudo14@hotmail.com) * @author <a href="mailto:adrian@jboss.org">Adrian Brock</a> * @version $Revision: 1.8 $ */ public class SpyQueueSession extends SpySession implements QueueSession, XAQueueSession { // Constants ----------------------------------------------------- // Attributes ---------------------------------------------------- // Static -------------------------------------------------------- // Constructors -------------------------------------------------- /** * Create a new SpyQueueSession * * @param myConnection the connection * @param transacted true for transacted, false otherwise * @param acknowledgeMode the acknowledgement mode */ SpyQueueSession(Connection myConnection, boolean transacted, int acknowledgeMode) { this(myConnection, transacted, acknowledgeMode, false); } /** * Create a new SpyQueueSession * * @param myConnection the connection * @param transacted true for transacted, false otherwise * @param acknowledgeMode the acknowledgement mode * @param xaSession true for xa, false otherwise */ SpyQueueSession(Connection myConnection, boolean transacted, int acknowledgeMode, boolean xaSession) { super(myConnection, transacted, acknowledgeMode, xaSession); } // Public -------------------------------------------------------- // XAQueueSession implementation --------------------------------- public QueueSession getQueueSession() throws javax.jms.JMSException { return this; } // Package protected --------------------------------------------- // Protected ----------------------------------------------------- // Private ------------------------------------------------------- // Inner classes ------------------------------------------------- }
SpyQueueSession.java |