[jboss-cvs] jboss-jms/src/main/org/jboss/jms/server/connectionfactory ...

[Timothy Fox]

  User: timfox  
  Date: 06/07/17 13:14:45

  Modified:    src/main/org/jboss/jms/server/connectionfactory  
                        ConnectionFactory.java
                        ConnectionFactoryJNDIMapper.java
  Log:
  Many changes including implementation of prefetch, SEDAisation of server, changing of recovery
  
  Revision  Changes    Path
  1.8       +14 -3     jboss-jms/src/main/org/jboss/jms/server/connectionfactory/ConnectionFactory.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: ConnectionFactory.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss-jms/src/main/org/jboss/jms/server/connectionfactory/ConnectionFactory.java,v
  retrieving revision 1.7
  retrieving revision 1.8
  diff -u -b -r1.7 -r1.8
  --- ConnectionFactory.java	18 May 2006 21:51:20 -0000	1.7
  +++ ConnectionFactory.java	17 Jul 2006 17:14:45 -0000	1.8
  @@ -19,9 +19,9 @@
    * A deployable JBoss Messaging connection factory.
    *
    * @author <a href="mailto:ovidiu at jboss.org">Ovidiu Feodorov</a>
  - * @version <tt>$Revision: 1.7 $</tt>
  + * @version <tt>$Revision: 1.8 $</tt>
    *
  - * $Id: ConnectionFactory.java,v 1.7 2006/05/18 21:51:20 ovidiu Exp $
  + * $Id: ConnectionFactory.java,v 1.8 2006/07/17 17:14:45 timfox Exp $
    */
   public class ConnectionFactory extends ServiceMBeanSupport
   {
  @@ -34,6 +34,7 @@
      protected String clientID;
      protected int connectionFactoryID;
      protected JNDIBindings jndiBindings;
  +   protected int prefetchSize = 150;
   
      protected ObjectName serverPeerObjectName;
      protected ConnectionFactoryManager connectionFactoryManager;
  @@ -97,7 +98,7 @@
         }
         
         connectionFactoryID = connectionFactoryManager.
  -         registerConnectionFactory(clientID, jndiBindings, locatorURI, enablePing);
  +         registerConnectionFactory(clientID, jndiBindings, locatorURI, enablePing, prefetchSize);
                 
         if (enablePing)
         {
  @@ -124,6 +125,16 @@
   
      // JMX managed attributes ----------------------------------------
   
  +   public int getPrefetchSize()
  +   {
  +      return prefetchSize;
  +   }
  +   
  +   public void setPrefetchSize(int prefetchSize)
  +   {
  +      this.prefetchSize = prefetchSize;
  +   }
  +
      public String getClientID()
      {
         return clientID;
  
  
  
  1.9       +6 -4      jboss-jms/src/main/org/jboss/jms/server/connectionfactory/ConnectionFactoryJNDIMapper.java
  
  (In the diff below, changes in quantity of whitespace are not shown.)
  
  Index: ConnectionFactoryJNDIMapper.java
  ===================================================================
  RCS file: /cvsroot/jboss/jboss-jms/src/main/org/jboss/jms/server/connectionfactory/ConnectionFactoryJNDIMapper.java,v
  retrieving revision 1.8
  retrieving revision 1.9
  diff -u -b -r1.8 -r1.9
  --- ConnectionFactoryJNDIMapper.java	13 Apr 2006 19:43:05 -0000	1.8
  +++ ConnectionFactoryJNDIMapper.java	17 Jul 2006 17:14:45 -0000	1.9
  @@ -43,9 +43,9 @@
   /**
    * @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: 1.8 $</tt>
  + * @version <tt>$Revision: 1.9 $</tt>
    *
  - * $Id: ConnectionFactoryJNDIMapper.java,v 1.8 2006/04/13 19:43:05 timfox Exp $
  + * $Id: ConnectionFactoryJNDIMapper.java,v 1.9 2006/07/17 17:14:45 timfox Exp $
    */
   public class ConnectionFactoryJNDIMapper implements ConnectionFactoryManager
   {
  @@ -76,12 +76,14 @@
      public synchronized int registerConnectionFactory(String clientID,
                                                        JNDIBindings jndiBindings,
                                                        String locatorURI,
  -                                                     boolean clientPing) throws Exception
  +                                                     boolean clientPing,
  +                                                     int prefetchSize) throws Exception
      {
         int id = serverPeer.getNextObjectID();
   
         ServerConnectionFactoryEndpoint endpoint =
  -         new ServerConnectionFactoryEndpoint(id, serverPeer, clientID, jndiBindings);
  +         new ServerConnectionFactoryEndpoint(id, serverPeer, clientID, jndiBindings,
  +                                             prefetchSize);
   
         ClientConnectionFactoryDelegate delegate;
         try