svn commit: r412783 - in /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq: ActiveMQConnection.java ActiveMQConnectionFactory.java

[chirino]

Author: chirino
Date: Thu Jun  8 08:50:29 2006
New Revision: 412783

URL: http://svn.apache.org/viewvc?rev=412783&view=rev
Log:
The onSendPrepareMessageBody connection property was not being used.  Removed 
it.

Modified:
    
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
    
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java

Modified: 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
URL: 
http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java?rev=412783&r1=412782&r2=412783&view=diff
==============================================================================
--- 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
 (original)
+++ 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
 Thu Jun  8 08:50:29 2006
@@ -118,7 +118,6 @@
     private ActiveMQPrefetchPolicy prefetchPolicy = new 
ActiveMQPrefetchPolicy();
     private RedeliveryPolicy redeliveryPolicy;
     private boolean disableTimeStampsByDefault = false;
-    private boolean onSendPrepareMessageBody = true;
     private boolean optimizedMessageDispatch = true;
     private boolean copyMessageOnSend = true;
     private boolean useCompression = false;
@@ -804,24 +803,6 @@
      */
     public void setCloseTimeout(int closeTimeout){
         this.closeTimeout=closeTimeout;
-    }
-
-
-    /**
-     * 
-     * @return Returns the onSendPrepareMessageBody.
-     */
-    public boolean isOnSendPrepareMessageBody() {
-        return onSendPrepareMessageBody;
-    }
-
-    /**
-     * 
-     * @param onSendPrepareMessageBody
-     *            The onSendPrepareMessageBody to set.
-     */
-    public void setOnSendPrepareMessageBody(boolean onSendPrepareMessageBody) {
-        this.onSendPrepareMessageBody = onSendPrepareMessageBody;
     }
 
     /**

Modified: 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java
URL: 
http://svn.apache.org/viewvc/incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java?rev=412783&r1=412782&r2=412783&view=diff
==============================================================================
--- 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java
 (original)
+++ 
incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java
 Thu Jun  8 08:50:29 2006
@@ -74,7 +74,6 @@
     private RedeliveryPolicy redeliveryPolicy = new RedeliveryPolicy();
 
     private boolean disableTimeStampsByDefault = false;
-    private boolean onSendPrepareMessageBody = true;
     private boolean optimizedMessageDispatch = true;
     private boolean copyMessageOnSend = true;
     private boolean useCompression = false;
@@ -228,7 +227,6 @@
             connection.setPassword(password);
             connection.setPrefetchPolicy(getPrefetchPolicy());
             
connection.setDisableTimeStampsByDefault(isDisableTimeStampsByDefault());
-            
connection.setOnSendPrepareMessageBody(isOnSendPrepareMessageBody());
             
connection.setOptimizedMessageDispatch(isOptimizedMessageDispatch());
             connection.setCopyMessageOnSend(isCopyMessageOnSend());
             connection.setUseCompression(isUseCompression());
@@ -413,7 +411,6 @@
         props.setProperty("copyMessageOnSend", 
Boolean.toString(isCopyMessageOnSend()));
         props.setProperty("disableTimeStampsByDefault", 
Boolean.toString(isDisableTimeStampsByDefault()));
         props.setProperty("objectMessageSerializationDefered", 
Boolean.toString(isObjectMessageSerializationDefered()));
-        props.setProperty("onSendPrepareMessageBody", 
Boolean.toString(isOnSendPrepareMessageBody()));
         props.setProperty("optimizedMessageDispatch", 
Boolean.toString(isOptimizedMessageDispatch()));
         props.setProperty("password", getPassword());
         props.setProperty("useAsyncSend", Boolean.toString(isUseAsyncSend()));
@@ -424,14 +421,6 @@
         props.setProperty("alwaysSessionAsync", 
Boolean.toString(isAlwaysSessionAsync()));
         props.setProperty("optimizeAcknowledge", 
Boolean.toString(isOptimizeAcknowledge()));
         
-    }
-
-    public boolean isOnSendPrepareMessageBody() {
-        return onSendPrepareMessageBody;
-    }
-
-    public void setOnSendPrepareMessageBody(boolean onSendPrepareMessageBody) {
-        this.onSendPrepareMessageBody = onSendPrepareMessageBody;
     }
 
     public boolean isUseCompression() {