[jboss-cvs] JBoss Messaging SVN: r1367 - trunk/src/main/org/jboss/jms/server/endpoint

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2006-09-26 16:22:20 -0400 (Tue, 26 Sep 2006)
New Revision: 1367

Removed:
   trunk/src/main/org/jboss/jms/server/endpoint/DeliveryRunnable.java
Log:
Removing DeliveryRunnable as it is not being used any more

Deleted: trunk/src/main/org/jboss/jms/server/endpoint/DeliveryRunnable.java
===================================================================
--- trunk/src/main/org/jboss/jms/server/endpoint/DeliveryRunnable.java	2006-09-26 18:42:33 UTC (rev 1366)
+++ trunk/src/main/org/jboss/jms/server/endpoint/DeliveryRunnable.java	2006-09-26 20:22:20 UTC (rev 1367)
@@ -1,117 +0,0 @@
-/*
-  * 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.server.endpoint;
-
-import org.jboss.jms.message.MessageProxy;
-import org.jboss.jms.server.ConnectionManager;
-import org.jboss.jms.server.remoting.MessagingMarshallable;
-import org.jboss.logging.Logger;
-
-/**
- * A PooledExecutor job that contains the message to be delivered asynchronously to the client. The
- * delivery is always carried on a thread pool thread.
- *
- * @author <a href="mailto:ovidiu at jboss.org">Ovidiu Feodorov</a>
- * @author <a href="mailto:tim.fox at jboss.com">Tim Fox</a>
- * @version <tt>$Revision$</tt>
- *
- * $Id$
- */
-public class DeliveryRunnable implements Runnable
-{
-   // Constants -----------------------------------------------------
-   
-   private static final Logger log = Logger.getLogger(DeliveryRunnable.class);
-
-   // Static --------------------------------------------------------
-   
-   // Attributes ----------------------------------------------------
-   
-   private boolean trace;
-   
-   private MessageProxy msg;
-         
-   private int consumerID;
-   
-   private ServerConnectionEndpoint connection;
-   
-   // Constructors --------------------------------------------------
-
-   public DeliveryRunnable(MessageProxy msg, int consumerID,
-                           ServerConnectionEndpoint connection, boolean trace)
-   {
-      this.msg = msg;
-      
-      this.connection = connection;
-      
-      this.consumerID = consumerID;
-      
-      this.trace = trace;
-   }
-
-   // Runnable implementation ---------------------------------------
-
-   public void run()
-   {
-      try
-      {
-         if (trace) { log.trace("handing " + this.msg + " over to the remoting layer"); }
-         
-         MessagingMarshallable mm = new MessagingMarshallable(connection.getUsingVersion(), this);
-         
-         connection.getCallbackClient().invoke(mm);         
-      }
-      catch(Throwable t)
-      {
-         log.warn("Failed to deliver the message to the client.");
-         
-         if (trace)
-         {
-            log.trace("Failed to deliver message", t);
-         }
-         
-         ConnectionManager mgr = connection.getServerPeer().getConnectionManager();
-         
-         mgr.handleClientFailure(connection.getRemotingClientSessionId());
-      }
-   }
-
-   // Public --------------------------------------------------------
-   
-   public MessageProxy getMessageProxy()
-   {
-      return msg;
-   }
-   
-   public int getConsumerID()
-   {
-      return consumerID;
-   }
-
-   // Package protected ---------------------------------------------
-   
-   // Protected -----------------------------------------------------
-   
-   // Private -------------------------------------------------------
-   
-   // Inner classes -------------------------------------------------   
-}