diff options
| -rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/message/MessageTransferMessage.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/message/MessageTransferMessage.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/message/MessageTransferMessage.java index 5b08b9fb52..9546025019 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/message/MessageTransferMessage.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/message/MessageTransferMessage.java @@ -70,7 +70,8 @@ public class MessageTransferMessage implements InboundMessage, ServerMessage public long getSize() { - return _messageProps.getContentLength(); + + return _xfr.getBodySize(); } public boolean isImmediate() |