activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r412783 - in /incubator/activemq/trunk/activemq-core/src/main/java/org/apache/activemq: ActiveMQConnection.java ActiveMQConnectionFactory.java
Date Thu, 08 Jun 2006 15:50:29 GMT
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() {



Mime
View raw message