diff options
Diffstat (limited to 'qpid/java/broker/src/main/java/org/apache/qpid/server/queue/TransientMessageData.java')
| -rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/queue/TransientMessageData.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/TransientMessageData.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/TransientMessageData.java index b09283b11f..791dfd101a 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/TransientMessageData.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/TransientMessageData.java @@ -120,8 +120,8 @@ public class TransientMessageData public boolean isPersistent() { - return _contentHeaderBody.properties instanceof BasicContentHeaderProperties && - ((BasicContentHeaderProperties) _contentHeaderBody.properties).getDeliveryMode() == + return _contentHeaderBody.getProperties() instanceof BasicContentHeaderProperties && + ((BasicContentHeaderProperties) _contentHeaderBody.getProperties()).getDeliveryMode() == BasicContentHeaderProperties.PERSISTENT; } } |