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

fixes for LargeStreamletTest 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@520865 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Robert Davies 2007-03-21 12:51:09 +00:00
parent 47510d8eee
commit 332aae366c
2 changed files with 14 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
activemq-core/src/main/java/org/apache/activemq/broker/region/QueueSubscription.java
View File

@ -131,7 +131,7 @@ public class QueueSubscription extends PrefetchSubscription implements LockOwner
if (message instanceof ActiveMQMessage) {
ActiveMQMessage activeMessage = (ActiveMQMessage) message;
try {
activeMessage.setBooleanProperty("JMSXGroupFirstForConsumer", true);
activeMessage.setBooleanProperty("JMSXGroupFirstForConsumer", true, false);
}
catch (JMSException e) {
log.warn("Failed to set boolean header: " + e, e);

16
activemq-core/src/main/java/org/apache/activemq/command/ActiveMQMessage.java
View File

@ -381,9 +381,16 @@ public class ActiveMQMessage extends Message implements org.apache.activemq.Mess
}
});
}
public void setObjectProperty(String name, Object value) throws JMSException{
setObjectProperty(name,value,true);
}
public void setObjectProperty(String name, Object value) throws JMSException {
checkReadOnlyProperties();
public void setObjectProperty(String name, Object value, boolean checkReadOnly) throws JMSException {
if (checkReadOnly) {
checkReadOnlyProperties();
}
if (name == null || name.equals("")) {
throw new IllegalArgumentException("Property name cannot be empty or null");
}
@ -535,7 +542,10 @@ public class ActiveMQMessage extends Message implements org.apache.activemq.Mess
}
public void setBooleanProperty(String name, boolean value) throws JMSException {
setObjectProperty(name, value ? Boolean.TRUE : Boolean.FALSE);
setBooleanProperty(name,value,true);
}
public void setBooleanProperty(String name, boolean value,boolean checkReadOnly) throws JMSException {
setObjectProperty(name, value ? Boolean.TRUE : Boolean.FALSE,checkReadOnly);
}
public void setByteProperty(String name, byte value) throws JMSException {