add a field for changing the callback factory.

Author: Ryan

src/main/com/mongodb/MongoOptions.java

@@ -18,6 +18,8 @@
 
 package com.mongodb;
 
+import com.mongodb.impl.*;
+
 import java.net.*;
 
 /**
@@ -41,66 +43,66 @@ public void reset(){
         w = 0;
         wtimeout = 0;
         fsync = false;
+        dbCallbackFactory = DBCallbackImpl.FACTORY;
     }
 
-    
     /**
-     * Helper method to return the appropriate WriteConcern instance based 
+     * Helper method to return the appropriate WriteConcern instance based
      * on the current related options settings.
      **/
     public WriteConcern getWriteConcern(){
         // Ensure we only set writeconcern once; if non-default w, etc skip safe (implied)
-        if ( w != 0 || wtimeout != 0 || fsync ) 
+        if ( w != 0 || wtimeout != 0 || fsync )
             return new WriteConcern( w , wtimeout , fsync );
-        else if (safe) 
+        else if (safe)
             return WriteConcern.SAFE;
         else
             return WriteConcern.NORMAL;
     }
 
     /**
-     * <p>The number of connections allowed per host 
+     * <p>The number of connections allowed per host
      * (the pool size, per host)</p>
-     * <p>Once the pool is exhausted, this will block. 
+     * <p>Once the pool is exhausted, this will block.
      * @see {@linkplain MongoOptions#threadsAllowedToBlockForConnectionMultiplier}</p>
      */
     public int connectionsPerHost;
 
     /**
-     *  multiplier for connectionsPerHost for # of threads that 
+     *  multiplier for connectionsPerHost for # of threads that
      *  can block if connectionsPerHost is 10, and
-     *  threadsAllowedToBlockForConnectionMultiplier is 5, 
+     *  threadsAllowedToBlockForConnectionMultiplier is 5,
      *  then 50 threads can block
      *  more than that and an exception will be throw
      */
     public int threadsAllowedToBlockForConnectionMultiplier;
-    
+
     /**
      * The max wait time for a blocking thread for a connection from the pool in ms.
      */
     public int maxWaitTime;
 
     /**
-     *  The connection timeout in milliseconds; this is for 
+     *  The connection timeout in milliseconds; this is for
      *  establishing the socket connections (open).
      *  0 is default and infinite
      */
     public int connectTimeout;
 
     /**
-     * The socket timeout; this value is passed to 
-     * {@link java.net.Socket#setSoTimeout(int)}.  
+     * The socket timeout; this value is passed to
+     * {@link java.net.Socket#setSoTimeout(int)}.
      * 0 is default and infinite
      */
     public int socketTimeout;
-    
+
     /**
      * This controls whether the system retries automatically
-     * on connection errors.  
+     * on connection errors.
      * defaults to false
      */
     public boolean autoConnectRetry;
-    
+
     /**
      * Specifies if the driver is allowed to read from secondaries
      * or slaves.
@@ -109,26 +111,32 @@ else if (safe)
      */
     public boolean slaveOk;
 
+    /**
+     * Override the DBCallback factory. Default is for the standard Mongo Java
+     * driver configuration.
+     */
+    public DBCallbackFactory dbCallbackFactory;
+
     /**
      * If <b>true</b> the driver sends a getLastError command after
      * every update to ensure it succeeded (see also w and wtimeout)
-     * If <b>false</b>, the driver does not send a getlasterror command 
+     * If <b>false</b>, the driver does not send a getlasterror command
      * after every update.
      *
      * defaults to false
      */
     public boolean safe;
 
     /**
-     * If set, the w value of WriteConcern for the connection is set 
+     * If set, the w value of WriteConcern for the connection is set
      * to this.
      *
      * Defaults to 0; implies safe = true
      */
     public int w;
 
     /**
-     * If set, the wtimeout value of WriteConcern for the 
+     * If set, the wtimeout value of WriteConcern for the
      * connection is set to this.
      *
      * Defaults to 0; implies safe = true
@@ -142,7 +150,6 @@ else if (safe)
      */
     public boolean fsync;
 
-    
     public String toString(){
         StringBuilder buf = new StringBuilder();
         buf.append( "connectionsPerHost: " ).append( connectionsPerHost ).append( " " );
@@ -159,5 +166,5 @@ public String toString(){
 
         return buf.toString();
     }
-    
+
 }