Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

The onSendPrepareMessageBody connection property was not being used. Removed it. 

git-svn-id: https://svn.apache.org/repos/asf/incubator/activemq/trunk@412783 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Hiram R. Chirino 2006-06-08 15:50:29 +00:00
parent c085df44f8
commit 1b4eb12723
2 changed files with 0 additions and 30 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
activemq-core/src/main/java/org/apache/activemq/ActiveMQConnection.java
View File

@ -118,7 +118,6 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
private ActiveMQPrefetchPolicy prefetchPolicy = new ActiveMQPrefetchPolicy(); private ActiveMQPrefetchPolicy prefetchPolicy = new ActiveMQPrefetchPolicy();
private RedeliveryPolicy redeliveryPolicy; private RedeliveryPolicy redeliveryPolicy;
private boolean disableTimeStampsByDefault = false; private boolean disableTimeStampsByDefault = false;
private boolean onSendPrepareMessageBody = true;
private boolean optimizedMessageDispatch = true; private boolean optimizedMessageDispatch = true;
private boolean copyMessageOnSend = true; private boolean copyMessageOnSend = true;
private boolean useCompression = false; private boolean useCompression = false;
@ -806,24 +805,6 @@ public class ActiveMQConnection implements Connection, TopicConnection, QueueCon
this.closeTimeout=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;
}
/** /**
* *
* @return ConnectionInfo * @return ConnectionInfo

11
activemq-core/src/main/java/org/apache/activemq/ActiveMQConnectionFactory.java
View File

@ -74,7 +74,6 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
private RedeliveryPolicy redeliveryPolicy = new RedeliveryPolicy(); private RedeliveryPolicy redeliveryPolicy = new RedeliveryPolicy();
private boolean disableTimeStampsByDefault = false; private boolean disableTimeStampsByDefault = false;
private boolean onSendPrepareMessageBody = true;
private boolean optimizedMessageDispatch = true; private boolean optimizedMessageDispatch = true;
private boolean copyMessageOnSend = true; private boolean copyMessageOnSend = true;
private boolean useCompression = false; private boolean useCompression = false;
@ -228,7 +227,6 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
connection.setPassword(password); connection.setPassword(password);
connection.setPrefetchPolicy(getPrefetchPolicy()); connection.setPrefetchPolicy(getPrefetchPolicy());
connection.setDisableTimeStampsByDefault(isDisableTimeStampsByDefault()); connection.setDisableTimeStampsByDefault(isDisableTimeStampsByDefault());
connection.setOnSendPrepareMessageBody(isOnSendPrepareMessageBody());
connection.setOptimizedMessageDispatch(isOptimizedMessageDispatch()); connection.setOptimizedMessageDispatch(isOptimizedMessageDispatch());
connection.setCopyMessageOnSend(isCopyMessageOnSend()); connection.setCopyMessageOnSend(isCopyMessageOnSend());
connection.setUseCompression(isUseCompression()); connection.setUseCompression(isUseCompression());
@ -413,7 +411,6 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
props.setProperty("copyMessageOnSend", Boolean.toString(isCopyMessageOnSend())); props.setProperty("copyMessageOnSend", Boolean.toString(isCopyMessageOnSend()));
props.setProperty("disableTimeStampsByDefault", Boolean.toString(isDisableTimeStampsByDefault())); props.setProperty("disableTimeStampsByDefault", Boolean.toString(isDisableTimeStampsByDefault()));
props.setProperty("objectMessageSerializationDefered", Boolean.toString(isObjectMessageSerializationDefered())); props.setProperty("objectMessageSerializationDefered", Boolean.toString(isObjectMessageSerializationDefered()));
props.setProperty("onSendPrepareMessageBody", Boolean.toString(isOnSendPrepareMessageBody()));
props.setProperty("optimizedMessageDispatch", Boolean.toString(isOptimizedMessageDispatch())); props.setProperty("optimizedMessageDispatch", Boolean.toString(isOptimizedMessageDispatch()));
props.setProperty("password", getPassword()); props.setProperty("password", getPassword());
props.setProperty("useAsyncSend", Boolean.toString(isUseAsyncSend())); props.setProperty("useAsyncSend", Boolean.toString(isUseAsyncSend()));
@ -426,14 +423,6 @@ public class ActiveMQConnectionFactory extends JNDIBaseStorable implements Conne
} }
public boolean isOnSendPrepareMessageBody() {
return onSendPrepareMessageBody;
}
public void setOnSendPrepareMessageBody(boolean onSendPrepareMessageBody) {
this.onSendPrepareMessageBody = onSendPrepareMessageBody;
}
public boolean isUseCompression() { public boolean isUseCompression() {
return useCompression; return useCompression;
} }