[jboss-cvs] JBoss Messaging SVN: r3675 - trunk/src/main/org/jboss/jms/destination.

jboss-cvs-commits at lists.jboss.org jboss-cvs-commits at lists.jboss.org
Thu Feb 7 13:22:23 EST 2008


Author: timfox
Date: 2008-02-07 13:22:23 -0500 (Thu, 07 Feb 2008)
New Revision: 3675

Added:
   trunk/src/main/org/jboss/jms/destination/JBossTemporaryQueue.java
   trunk/src/main/org/jboss/jms/destination/JBossTemporaryTopic.java
Log:
Added missing files


Added: trunk/src/main/org/jboss/jms/destination/JBossTemporaryQueue.java
===================================================================
--- trunk/src/main/org/jboss/jms/destination/JBossTemporaryQueue.java	                        (rev 0)
+++ trunk/src/main/org/jboss/jms/destination/JBossTemporaryQueue.java	2008-02-07 18:22:23 UTC (rev 3675)
@@ -0,0 +1,82 @@
+/*
+  * JBoss, Home of Professional Open Source
+  * Copyright 2005, JBoss Inc., and individual contributors as indicated
+  * by the @authors tag. See the copyright.txt in the distribution for a
+  * full listing of individual contributors.
+  *
+  * This is free software; you can redistribute it and/or modify it
+  * under the terms of the GNU Lesser General Public License as
+  * published by the Free Software Foundation; either version 2.1 of
+  * the License, or (at your option) any later version.
+  *
+  * This software is distributed in the hope that it will be useful,
+  * but WITHOUT ANY WARRANTY; without even the implied warranty of
+  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+  * Lesser General Public License for more details.
+  *
+  * You should have received a copy of the GNU Lesser General Public
+  * License along with this software; if not, write to the Free
+  * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+  * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+  */
+package org.jboss.jms.destination;
+
+import javax.jms.JMSException;
+import javax.jms.TemporaryQueue;
+
+import org.jboss.jms.client.JBossSession;
+
+/**
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
+ * @version <tt>$Revision: 3569 $</tt>
+ *
+ * $Id: JBossQueue.java 3569 2008-01-15 21:14:04Z timfox $
+ */
+public class JBossTemporaryQueue extends JBossQueue implements TemporaryQueue
+{   
+   // Constants -----------------------------------------------------
+   
+   private static final long serialVersionUID = 8957042889037273330L;
+   
+   // Static --------------------------------------------------------
+   
+   // Attributes ----------------------------------------------------
+   
+   private transient JBossSession session;
+   
+   // Constructors --------------------------------------------------
+
+   public JBossTemporaryQueue(JBossSession session, String name)
+   {
+      super(name);
+      
+      this.session = session;
+   }
+   
+   // TemporaryQueue implementation ------------------------------------------
+
+   public void delete() throws JMSException
+   {      
+      session.deleteTemporaryDestination(this);
+   }
+
+   // Public --------------------------------------------------------
+   
+   public boolean isTemporary()
+   {
+      return true;
+   }
+      
+   public String toString()
+   {
+      return "JBossTemporaryQueue[" + name + "]";
+   }
+
+   // Package protected ---------------------------------------------
+   
+   // Protected -----------------------------------------------------
+   
+   // Private -------------------------------------------------------
+   
+   // Inner classes -------------------------------------------------   
+}

Added: trunk/src/main/org/jboss/jms/destination/JBossTemporaryTopic.java
===================================================================
--- trunk/src/main/org/jboss/jms/destination/JBossTemporaryTopic.java	                        (rev 0)
+++ trunk/src/main/org/jboss/jms/destination/JBossTemporaryTopic.java	2008-02-07 18:22:23 UTC (rev 3675)
@@ -0,0 +1,82 @@
+/*
+  * JBoss, Home of Professional Open Source
+  * Copyright 2005, JBoss Inc., and individual contributors as indicated
+  * by the @authors tag. See the copyright.txt in the distribution for a
+  * full listing of individual contributors.
+  *
+  * This is free software; you can redistribute it and/or modify it
+  * under the terms of the GNU Lesser General Public License as
+  * published by the Free Software Foundation; either version 2.1 of
+  * the License, or (at your option) any later version.
+  *
+  * This software is distributed in the hope that it will be useful,
+  * but WITHOUT ANY WARRANTY; without even the implied warranty of
+  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+  * Lesser General Public License for more details.
+  *
+  * You should have received a copy of the GNU Lesser General Public
+  * License along with this software; if not, write to the Free
+  * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
+  * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
+  */
+package org.jboss.jms.destination;
+
+import javax.jms.JMSException;
+import javax.jms.TemporaryTopic;
+
+import org.jboss.jms.client.JBossSession;
+
+/**
+ * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
+ * @version <tt>$Revision: 3569 $</tt>
+ *
+ * $Id: JBossQueue.java 3569 2008-01-15 21:14:04Z timfox $
+ */
+public class JBossTemporaryTopic extends JBossTopic implements TemporaryTopic
+{      
+   // Constants -----------------------------------------------------
+      
+   private static final long serialVersionUID = -8455283004195652511L;
+
+   // Static --------------------------------------------------------
+   
+   // Attributes ----------------------------------------------------
+   
+   private transient JBossSession session;
+      
+   // Constructors --------------------------------------------------
+
+   public JBossTemporaryTopic(JBossSession session, String name)
+   {
+      super(name);
+      
+      this.session = session;
+   }
+   
+   // TemporaryQueue implementation ------------------------------------------
+
+   public void delete() throws JMSException
+   {      
+      session.deleteTemporaryDestination(this);
+   }
+
+   // Public --------------------------------------------------------
+   
+   public boolean isTemporary()
+   {
+      return true;
+   }
+      
+   public String toString()
+   {
+      return "JBossTemporaryTopic[" + name + "]";
+   }
+
+   // Package protected ---------------------------------------------
+   
+   // Protected -----------------------------------------------------
+   
+   // Private -------------------------------------------------------
+   
+   // Inner classes -------------------------------------------------   
+}




More information about the jboss-cvs-commits mailing list