1 files changed, 2 insertions, 2 deletions
diff --git a/cpp/src/qpid/broker/PagedQueue.cpp b/cpp/src/qpid/broker/PagedQueue.cpp
index afb330489b..a63f6d2485 100644
--- a/cpp/src/qpid/broker/PagedQueue.cpp
+++ b/cpp/src/qpid/broker/PagedQueue.cpp
@@ -78,8 +78,8 @@ size_t decode(ProtocolRegistry& protocols, Message& msg, const char* data, size_
     msg.getPersistentContext()->setPersistenceId(persistenceId);
     if (t) {
         sys::AbsTime expiration(EPOCH, t);
-        msg.setExpiryPolicy(expiryPolicy);
-        msg.setExpiration(expiration);
+        msg.getSharedState().setExpiryPolicy(expiryPolicy);
+        msg.getSharedState().setExpiration(expiration);
     }
     return encoded + metadata.getPosition();
 }