You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ar...@apache.org on 2007/11/27 09:36:43 UTC
svn commit: r598559 -
/incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/BasicContentHeaderProperties.java
Author: arnaudsimon
Date: Tue Nov 27 00:36:43 2007
New Revision: 598559
URL: http://svn.apache.org/viewvc?rev=598559&view=rev
Log:
optimized message creation
Modified:
incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/BasicContentHeaderProperties.java
Modified: incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/BasicContentHeaderProperties.java
URL: http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/BasicContentHeaderProperties.java?rev=598559&r1=598558&r2=598559&view=diff
==============================================================================
--- incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/BasicContentHeaderProperties.java (original)
+++ incubator/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/framing/BasicContentHeaderProperties.java Tue Nov 27 00:36:43 2007
@@ -96,6 +96,23 @@
private static final int APPLICATION_ID_MASK = 1 << 3;
private static final int CLUSTER_ID_MASK = 1 << 2;
+
+ /**
+ * This is 0_10 specific. We use this property to check if some message properties have been changed.
+ */
+ private boolean _hasBeenUpdated = false;
+
+ public boolean reset()
+ {
+ boolean result = _hasBeenUpdated;
+ _hasBeenUpdated = false;
+ return result;
+ }
+ public void updated()
+ {
+ _hasBeenUpdated = true;
+ }
+
public BasicContentHeaderProperties()
{ }
@@ -202,6 +219,7 @@
public void setPropertyFlags(int propertyFlags)
{
+ _hasBeenUpdated = true;
clearEncodedForm();
_propertyFlags = propertyFlags;
}
@@ -491,6 +509,7 @@
public void setContentType(AMQShortString contentType)
{
+ _hasBeenUpdated = true;
clearEncodedForm();
_propertyFlags |= (CONTENT_TYPE_MASK);
_contentType = contentType;
@@ -498,6 +517,7 @@
public void setContentType(String contentType)
{
+ _hasBeenUpdated = true;
setContentType((contentType == null) ? null : new AMQShortString(contentType));
}
@@ -516,6 +536,7 @@
public void setEncoding(String encoding)
{
+ _hasBeenUpdated = true;
clearEncodedForm();
_propertyFlags |= ENCONDING_MASK;
_encoding = (encoding == null) ? null : new AMQShortString(encoding);
@@ -523,6 +544,7 @@
public void setEncoding(AMQShortString encoding)
{
+ _hasBeenUpdated = true;
clearEncodedForm();
_propertyFlags |= ENCONDING_MASK;
_encoding = encoding;
@@ -542,6 +564,7 @@
public void setHeaders(FieldTable headers)
{
+ _hasBeenUpdated = true;
clearEncodedForm();
_propertyFlags |= HEADERS_MASK;
_headers = headers;
@@ -591,11 +614,13 @@
public void setCorrelationId(String correlationId)
{
+ _hasBeenUpdated = true;
setCorrelationId((correlationId == null) ? null : new AMQShortString(correlationId));
}
public void setCorrelationId(AMQShortString correlationId)
{
+ _hasBeenUpdated = true;
clearEncodedForm();
_propertyFlags |= CORRELATION_ID_MASK;
_correlationId = correlationId;
@@ -617,12 +642,13 @@
public void setReplyTo(String replyTo)
{
+ _hasBeenUpdated = true;
setReplyTo((replyTo == null) ? null : new AMQShortString(replyTo));
}
public void setReplyTo(AMQShortString replyTo)
{
-
+ _hasBeenUpdated = true;
clearEncodedForm();
_propertyFlags |= REPLY_TO_MASK;
_replyTo = replyTo;
@@ -631,7 +657,6 @@
public long getExpiration()
{
decodeIfNecessary();
-
return _expiration;
}
@@ -665,6 +690,7 @@
public void setMessageId(AMQShortString messageId)
{
+ _hasBeenUpdated = true;
clearEncodedForm();
_propertyFlags |= MESSAGE_ID_MASK;
_messageId = messageId;
@@ -673,7 +699,6 @@
public long getTimestamp()
{
decodeIfNecessary();
-
return _timestamp;
}
@@ -700,11 +725,13 @@
public void setType(String type)
{
+ _hasBeenUpdated = true;
setType((type == null) ? null : new AMQShortString(type));
}
public void setType(AMQShortString type)
{
+ _hasBeenUpdated = true;
clearEncodedForm();
_propertyFlags |= TYPE_MASK;
_type = type;
@@ -731,6 +758,7 @@
public void setUserId(AMQShortString userId)
{
+ _hasBeenUpdated = true;
clearEncodedForm();
_propertyFlags |= USER_ID_MASK;
_userId = userId;
@@ -752,37 +780,42 @@
public void setAppId(String appId)
{
+ _hasBeenUpdated = true;
setAppId((appId == null) ? null : new AMQShortString(appId));
}
public void setAppId(AMQShortString appId)
{
+ _hasBeenUpdated = true;
clearEncodedForm();
_propertyFlags |= APPLICATION_ID_MASK;
_appId = appId;
+ _hasBeenUpdated = true;
}
public String getClusterIdAsString()
{
+ _hasBeenUpdated = true;
decodeIfNecessary();
-
return (_clusterId == null) ? null : _clusterId.toString();
}
public AMQShortString getClusterId()
{
+ _hasBeenUpdated = true;
decodeIfNecessary();
-
return _clusterId;
}
public void setClusterId(String clusterId)
{
+ _hasBeenUpdated = true;
setClusterId((clusterId == null) ? null : new AMQShortString(clusterId));
}
public void setClusterId(AMQShortString clusterId)
{
+ _hasBeenUpdated = true;
clearEncodedForm();
_propertyFlags |= CLUSTER_ID_MASK;
_clusterId = clusterId;