[jboss-cvs] JBoss Messaging SVN: r5434 - in trunk/src/main/org/jboss/messaging/core/client: impl and 1 other directory.

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

Author: ataylor
Date: 2008-11-25 10:43:08 -0500 (Tue, 25 Nov 2008)
New Revision: 5434

Modified:
   trunk/src/main/org/jboss/messaging/core/client/ClientSessionFactory.java
   trunk/src/main/org/jboss/messaging/core/client/impl/ClientSessionFactoryImpl.java
Log:
tweaks for preack mode

Modified: trunk/src/main/org/jboss/messaging/core/client/ClientSessionFactory.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/client/ClientSessionFactory.java	2008-11-25 12:51:55 UTC (rev 5433)
+++ trunk/src/main/org/jboss/messaging/core/client/ClientSessionFactory.java	2008-11-25 15:43:08 UTC (rev 5434)
@@ -89,6 +89,10 @@
 
    void setAckBatchSize(int ackBatchSize);
 
+   boolean isPreAcknowledge();
+
+   void setPreAcknowledge(boolean preAcknowledge);
+   
    ConnectorFactory getConnectorFactory();
 
    Map<String, Object> getTransportParams();

Modified: trunk/src/main/org/jboss/messaging/core/client/impl/ClientSessionFactoryImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/client/impl/ClientSessionFactoryImpl.java	2008-11-25 12:51:55 UTC (rev 5433)
+++ trunk/src/main/org/jboss/messaging/core/client/impl/ClientSessionFactoryImpl.java	2008-11-25 15:43:08 UTC (rev 5434)
@@ -126,6 +126,8 @@
    private volatile boolean blockOnNonPersistentSend;
 
    private volatile boolean autoGroup;
+
+   private boolean preAcknowledge;
    
    private volatile int ackBatchSize;
 
@@ -208,6 +210,7 @@
       this.autoGroup = autoGroup;
       this.maxConnections = maxConnections;
       this.ackBatchSize = ackBatchSize;
+      this.preAcknowledge = preAcknowledge;
    }
 
    public ClientSessionFactoryImpl(final TransportConfiguration connectorConfig,
@@ -257,7 +260,7 @@
                                       final boolean autoCommitSends,
                                       final boolean autoCommitAcks) throws MessagingException
    {
-      return createSessionInternal(null, null, xa, autoCommitSends, autoCommitAcks, false, ackBatchSize);
+      return createSessionInternal(null, null, xa, autoCommitSends, autoCommitAcks, preAcknowledge, ackBatchSize);
    }
 
    public ClientSession createSession(final boolean xa,
@@ -358,6 +361,16 @@
       this.ackBatchSize = ackBatchSize;
    }
 
+   public boolean isPreAcknowledge()
+   {
+      return preAcknowledge;
+   }
+
+   public void setPreAcknowledge(boolean preAcknowledge)
+   {
+      this.preAcknowledge = preAcknowledge;
+   }
+
    public ConnectorFactory getConnectorFactory()
    {
       return connectorFactory;