diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2007-05-09 15:23:33 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2007-05-09 15:23:33 +0000 |
| commit | 1bb43f379eda76afca9df488cd9510f60ad89717 (patch) | |
| tree | 79d2646c711b4dcd7c96bff4e2f090fb322053ed /java/common/src | |
| parent | a3e675e90525a5614e656a0ffdac355364d56e28 (diff) | |
| download | qpid-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.java | 33 |
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) |
