summaryrefslogtreecommitdiff
path: root/java/common/src
diff options
context:
space:
mode:
authorMartin Ritchie <ritchiem@apache.org>2007-05-09 15:23:33 +0000
committerMartin Ritchie <ritchiem@apache.org>2007-05-09 15:23:33 +0000
commit1bb43f379eda76afca9df488cd9510f60ad89717 (patch)
tree79d2646c711b4dcd7c96bff4e2f090fb322053ed /java/common/src
parenta3e675e90525a5614e656a0ffdac355364d56e28 (diff)
downloadqpid-python-1bb43f379eda76afca9df488cd9510f60ad89717.tar.gz
Merged revisions 536498-536499 via svnmerge from
https://svn.apache.org/repos/asf/incubator/qpid/branches/M2 ........ r536498 | ritchiem | 2007-05-09 13:15:55 +0100 (Wed, 09 May 2007) | 1 line Moved MaxChannelsTest.java to the correct package. ........ r536499 | ritchiem | 2007-05-09 13:16:17 +0100 (Wed, 09 May 2007) | 1 line Whitespace + Formatting. ........ git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@536565 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/common/src')
-rw-r--r--java/common/src/main/java/org/apache/qpid/framing/BasicContentHeaderProperties.java33
1 files changed, 15 insertions, 18 deletions
diff --git a/java/common/src/main/java/org/apache/qpid/framing/BasicContentHeaderProperties.java b/java/common/src/main/java/org/apache/qpid/framing/BasicContentHeaderProperties.java
index dd872c31b0..4424fc1def 100644
--- a/java/common/src/main/java/org/apache/qpid/framing/BasicContentHeaderProperties.java
+++ b/java/common/src/main/java/org/apache/qpid/framing/BasicContentHeaderProperties.java
@@ -31,26 +31,23 @@ public class BasicContentHeaderProperties implements CommonContentHeaderProperti
private static final AMQShortString ZERO_STRING = null;
/**
- * We store the encoded form when we decode the content header so that if we need to
- * write it out without modifying it we can do so without incurring the expense of
- * reencoding it
+ * We store the encoded form when we decode the content header so that if we need to write it out without modifying
+ * it we can do so without incurring the expense of reencoding it
*/
private byte[] _encodedForm;
- /**
- * Flag indicating whether the entire content header has been decoded yet
- */
+ /** Flag indicating whether the entire content header has been decoded yet */
private boolean _decoded = true;
/**
- * We have some optimisations for partial decoding for maximum performance. The headers are used in the broker
- * for routing in some cases so we can decode that separately.
+ * We have some optimisations for partial decoding for maximum performance. The headers are used in the broker for
+ * routing in some cases so we can decode that separately.
*/
private boolean _decodedHeaders = true;
/**
- * We have some optimisations for partial decoding for maximum performance. The content type is used by all
- * clients to determine the message type
+ * We have some optimisations for partial decoding for maximum performance. The content type is used by all clients
+ * to determine the message type
*/
private boolean _decodedContentType = true;
@@ -142,9 +139,9 @@ public class BasicContentHeaderProperties implements CommonContentHeaderProperti
}
if ((_propertyFlags & EXPIRATION_MASK) > 0)
{
- if(_expiration == 0L)
+ if (_expiration == 0L)
{
- size+=EncodingUtils.encodedShortStringLength(ZERO_STRING);
+ size += EncodingUtils.encodedShortStringLength(ZERO_STRING);
}
else
{
@@ -237,9 +234,9 @@ public class BasicContentHeaderProperties implements CommonContentHeaderProperti
}
if ((_propertyFlags & EXPIRATION_MASK) != 0)
{
- if(_expiration == 0L)
+ if (_expiration == 0L)
{
- EncodingUtils.writeShortStringBytes(buffer, ZERO_STRING);
+ EncodingUtils.writeShortStringBytes(buffer, ZERO_STRING);
}
else
{
@@ -274,7 +271,7 @@ public class BasicContentHeaderProperties implements CommonContentHeaderProperti
}
public void populatePropertiesFromBuffer(ByteBuffer buffer, int propertyFlags, int size)
- throws AMQFrameDecodingException
+ throws AMQFrameDecodingException
{
_propertyFlags = propertyFlags;
@@ -463,7 +460,7 @@ public class BasicContentHeaderProperties implements CommonContentHeaderProperti
public String getEncodingAsString()
{
-
+
return getEncoding() == null ? null : getEncoding().toString();
}
@@ -575,7 +572,7 @@ public class BasicContentHeaderProperties implements CommonContentHeaderProperti
{
setReplyTo(replyTo == null ? null : new AMQShortString(replyTo));
}
-
+
public void setReplyTo(AMQShortString replyTo)
{
@@ -702,7 +699,7 @@ public class BasicContentHeaderProperties implements CommonContentHeaderProperti
public void setAppId(String appId)
{
- setAppId(appId == null ? null : new AMQShortString(appId));
+ setAppId(appId == null ? null : new AMQShortString(appId));
}
public void setAppId(AMQShortString appId)